From 45b2d06936f884a8bbeee890923a879437f0e5ef Mon Sep 17 00:00:00 2001 From: Rick Parker Date: Fri, 26 Apr 2019 09:33:27 +0100 Subject: [PATCH] CORDA-2845 Drop the acknowledge window for RPC responses to 16KB from 1MB because the memory footprint is multipled by the number of RPC clients. (#4997) --- .../net/corda/client/rpc/internal/RPCClientProxyHandler.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/RPCClientProxyHandler.kt b/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/RPCClientProxyHandler.kt index ee9acfe3b4..725ff71fff 100644 --- a/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/RPCClientProxyHandler.kt +++ b/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/RPCClientProxyHandler.kt @@ -513,7 +513,7 @@ class RPCClientProxyHandler( private fun initSessions() { producerSession = sessionFactory!!.createSession(rpcUsername, rpcPassword, false, true, true, false, DEFAULT_ACK_BATCH_SIZE) rpcProducer = producerSession!!.createProducer(RPCApi.RPC_SERVER_QUEUE_NAME) - consumerSession = sessionFactory!!.createSession(rpcUsername, rpcPassword, false, true, true, false, DEFAULT_ACK_BATCH_SIZE) + consumerSession = sessionFactory!!.createSession(rpcUsername, rpcPassword, false, true, true, false, 16384) consumerSession!!.createTemporaryQueue(clientAddress, RoutingType.ANYCAST, clientAddress) rpcConsumer = consumerSession!!.createConsumer(clientAddress) rpcConsumer!!.setMessageHandler(this::artemisMessageHandler)