proxy client

gistfile1.scala

val system = ActorSystem("MySystem")
val connFactory = new ConnectionFactory()
connFactory.setHost("rabbitmq")
val conn = system.actorOf(
  Props(new ConnectionOwner(connFactory)), 
  name = "conn")
val client = ConnectionOwner.createActor(
  conn, 
  Props(new RpcClient()), 
  5 second)
waitForConnection(system, client).await()
val proxy = system.actorOf(
  Props(
     new AmqpProxy.ProxyClient(
        client, 
        "amq.direct", 
        "calculator",    
        JsonSerializer
     )
  ),
  name = "proxy"
)

compute(proxy)