isher = Sink(connection.publish("exchange_name"))
</code>
</pre>
        
        <h3>Processing messages</h3>
        <p>
        To split the work into logical parts we are using <b><code>Flow[In, Out]</code></b> on which we're applying multiple transformations (like map, mapFuture, groupBy). This allows us to define some message processing independently from the publisher and subscriber and connect them later. All the <code>Flows</code> are defined in the <a href="#code/src/main/scala/io/scalac/rabbit/Fl