From c3af80f40bb7a4349f89b2b6ced4f176dea0d7e1 Mon Sep 17 00:00:00 2001 From: momania Date: Fri, 12 Nov 2010 14:24:06 +0100 Subject: [PATCH] minor simplification --- akka-amqp/src/main/scala/akka/amqp/ExampleSession.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-amqp/src/main/scala/akka/amqp/ExampleSession.scala b/akka-amqp/src/main/scala/akka/amqp/ExampleSession.scala index 55e5a07f82..0e14f1b3bb 100644 --- a/akka-amqp/src/main/scala/akka/amqp/ExampleSession.scala +++ b/akka-amqp/src/main/scala/akka/amqp/ExampleSession.scala @@ -200,7 +200,7 @@ object ExampleSession { def requestHandler(request: String) = 3 - val rpcServer = RPC.newRpcServer[String,Int](connection, exchangeName, rpcServerSerializer, requestHandler _, + val rpcServer = RPC.newRpcServer(connection, exchangeName, rpcServerSerializer, requestHandler _, routingKey = Some("rpc.in.key"), queueName = Some("rpc.in.key.queue")) @@ -213,7 +213,7 @@ object ExampleSession { } val rpcClientSerializer = new RpcClientSerializer[String, Int](clientToBinary, clientFromBinary) - val rpcClient = RPC.newRpcClient[String,Int](connection, exchangeName, rpcClientSerializer, Some("rpc.in.key")) + val rpcClient = RPC.newRpcClient(connection, exchangeName, rpcClientSerializer, Some("rpc.in.key")) val response = rpcClient.call("rpc_request") log.info("Response: " + response)