Replaced usage of QueueingConsumer with custom class and added documentation.