If you have some blocking code in a MessageListener which throws InterrupedException it isn't raised when you call consumer.close.
There are legit reasons for this including blocking on a CountdownLatch.. otherwise I have to implement code to poll() checking if the consumers have been closed ... -- We’re hiring if you know of any awesome Java Devops or Linux Operations Engineers! Founder/CEO Spinn3r.com Location: *San Francisco, CA* blog: http://burtonator.wordpress.com … or check out my Google+ profile <https://plus.google.com/102718274791889610666/posts>
