gistfile1.scala

val myAddresses = Array(new Address("mq1", 5672), new Address("mq2", 5672))
val connectionParameters = ConnectionParameters(myAddresses, "guest", "guest", "/")
val connection = AMQP.newConnection(connectionParameters)
val exchangeParameters = ExchangeParameters("foo", Direct, PassiveDeclaration)
val smallPrefetchChannelParameters = Some(ChannelParameters(prefetchSize = 0))
AMQP.newConsumer(
  connection = connection,
  consumerParameters = ConsumerParameters(
    routingKey = "bar",
    deliveryHandler = Actor.actorOf(new JobConsumer(1)),
    exchangeParameters = Some(exchangeParameters),
    channelParameters = smallPrefetchChannelParameters))
...

class JobConsumer(id: Int) extends Actor {
  self.id = "jobconsumer-" + id

  def receive = {
    case Delivery(payload, _, _, _, _, _) =>
      println(self.id + " received message: " + new String(payload))
  }
}