 <p>
        It is worth noting that the <b>Publisher</b> and <b>Subscriber</b> returned from <b>Connection</b> are both interfaces defined by <a href="http://www.reactive-streams.org/">Rective Streams</a> specification. That means Reactive Rabbit can be integrated with any implementation of the specification. Here we're using it with Akka Streams by wrapping Publisher and Subscriber into <b>Source</b> and <b>Sink</b>.
<pre>
<code>
val rabbitConsumer = Source(connection.consume("queue_name"))
val rabbitPubl