Went to implementing amqplib, instead of amqp...It seems easier and I have a pub/sub process going on in rabbitmq.js