An activity streaming library sending events to RabbitMQ