Refactor the Pipelines and Endpoints
Working InMemory implementation
Create separate IRabbitMqPipeline interface.