Implemented StreamProcessor based on Publisher/Subscriber model and RabbitMQ.