Added ability to stop consuming and therefore ending the listener threads