@@ -1,21 +1,33 @@ package eu.getintheloop.example.rabbit -import _root_.com.rabbitmq.client.{ConnectionFactory,ConnectionParameters} -import _root_.net.liftweb.amqp.{ExampleSerializedAMQPDispatcher,AMQPAddListener,AMQPMessage} +import _root_.com.rabbitmq.client.{ConnectionFactory,ConnectionParameters,Channel} +import _root_.net.liftweb.amqp.{AMQPDispatcher,AMQPAddListener,AMQPMessage,SerializedConsumer} import _root_.scala.actors._ -object BasicStringListener { +class DemonstrationSerializedAMQPDispatcher[T](queueName: String, factory: ConnectionFactory, host: String, port: Int) extends AMQPDispatcher[T](factory, host, port) { + override def configure(channel: Channel) { + // Get the ticket. + val ticket = channel.accessRequest("/data") + // Set up the exchange and queue + channel.exchangeDeclare(ticket, "mult", "fanout") + channel.queueDeclare(ticket, queueName) + channel.queueBind(ticket, queueName, "mult", "example.*") + // Use the short version of the basicConsume method for convenience. + channel.basicConsume(ticket, queueName, false, new SerializedConsumer(channel, this)) + } +} + +class BasicStringListener(queueName: String) { val params = new ConnectionParameters params.setUsername("guest") params.setPassword("guest") params.setVirtualHost("/") params.setRequestedHeartbeat(0) - + val factory = new ConnectionFactory(params) - // thor.local is a machine on your network with rabbitmq listening on port 5672 - val amqp = new ExampleSerializedAMQPDispatcher[String](factory, "localhost", 5672) + val amqp = new DemonstrationSerializedAMQPDispatcher[String](queueName, factory, "xmpiemacbookpro", 5672) amqp.start - + // Example Listener that just prints the String it receives. class StringListener extends Actor { def act = { @@ -28,3 +40,4 @@ object BasicStringListener { stringListener.start amqp ! AMQPAddListener(stringListener) } + client/src/main/scala/eu/getintheloop/example/rabbit/BasicStringListener.scala @@ -22,7 +22,7 @@ object BasicStringSender { // Create a new instance of the string sender. // This sender will send messages to the "mult" exchange with a // routing key of "routeroute" - val amqp = new StringAMQPSender(factory, "localhost", 5672, "mult", "routeroute") + val amqp = new StringAMQPSender(factory, "xmpiemacbookpro", 5672, "mult", "example.demo") amqp.start /** server/src/main/scala/eu/getintheloop/example/rabbit/BasicStringSender.scala 055374065f798405d0632f3d2c925f979ee4fa5b Timothy Perrett hello@timperrett.com http://github.com/timperrett/rabbitmq-scala-tutorial/commit/1d6929d7bb788eebc9a0699a56f8fd443e48a3b5 1d6929d7bb788eebc9a0699a56f8fd443e48a3b5 2009-05-22T04:39:00-07:00 2009-05-22T04:39:00-07:00 Updated working code ad4bcce3a580fa4d3b9a684c6a1e96eda0287001 Timothy Perrett hello@timperrett.com