proxy server

gistfile1.scala

val system = ActorSystem("MySystem")
val calc = system.actorOf(Props[Calculator])
val connFactory = new ConnectionFactory()
connFactory.setHost("localhost")
val conn = system.actorOf(
  Props(new ConnectionOwner(connFactory)), 
  name = "conn")
val exchange = ExchangeParameters(name = "amq.direct", exchangeType = "", passive = true)
val queue = QueueParameters(name = "calculator", passive = false, autodelete = true)
val channelParams = Some(ChannelParameters(qos = 1))
// create an AMQP RPC server which consumes messages from queue "calculator"
// and passes them to our Calculator actor
val server = ConnectionOwner.createActor(
     conn,
     Props(
         new RpcServer(
             queue, 
             exchange, 
             "calculator", 
             new AmqpProxy.ProxyServer(calc, JsonSerializer), 
             channelParams
         )
     ),
     2 second)

waitForConnection(system, server).await()