Now using concrete Operator types instead of Pipeline with Actions. Started RabbitMQ adapter.