* Update consume to accept new feature

* Move disconnect to callback

* Made use of exclusive queue

* Disconnect in message handlers

Since we are using exclusive queue, simply disconnect from it will
remove the queue