the description for this gist

post.scala

class ExchangeConsumerReactiveSubscriberSpec
  extends SubscriberBlackboxVerification[OutboundMessage](
    new TestEnvironment(300)
  ) with TestNGSuiteLike {

  /* RabbitMQ setup and cleanup code here */ 

  implicit val scheduler = Scheduler.io()

  override def createSubscriber() =
    new ExchangeConsumer(connection, ExchangeName)
      .createSubscriber(Callback.empty, scheduler)
      ._1.toReactive

  override def createElement(element: Int) =
    OutboundMessage(routingKey = "foo", body = BigInt(element).toByteArray)
}