Added logic to push messages to Queues