raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

minor simplification

Browse source
This commit is contained in:
momania 2010-11-12 14:24:06 +01:00
parent bc7746493c
commit c3af80f40b
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-amqp/src/main/scala/akka/amqp/ExampleSession.scala
View file

@ -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)