Module worker 

Structs

QueueMessage

Raw queue message consumed by the worker.

StreamWorker

Consumes the write queue, persists events, and pipes to ready read streams.

Traits

QueueConsumer

Abstraction over the RabbitMQ queue consumer loop.