added utility to pull messages from amqp