Refactored to work with amqp 0.8.0. Using a queue-subscribe model instead of long polling for new messages.
Refactored to work with amqp 0.8.0. Using a queue-subscribe model instead of long polling for new messages.

blockbridge/goliath