Things the repo lacks: 1. multiple queues 2. mutiple handlers based on particular event type (there could be multiple callbacks, we could one based on some eventType parameter from the message)