tidy unused vars, provide support for workers to re-inject messages to other queues