owFactory.scala" class="shortcut">FlowFactory</a> trait.
        </p>
        <h3>Putting it all together</h3>
        <p>
        After everything is set up we can combine all the parts into one processing pipeline and run the flow. Akka Streams provides us with an awesome, readable and clean DSL for this purpose: 
        </p>
<pre>
<code>
val flow = rabbitConsumer via consumerMapping via domainProcessing via publisherMapping to rabbitPublisher
    
flow.run()
</code>
</pre>
    </div>
    <div>
        <