From 91779276fc405835f1f5bf74642dd8c567161748 Mon Sep 17 00:00:00 2001 From: Andras Slemmer Date: Fri, 12 Jan 2018 15:22:56 +0000 Subject: [PATCH] Use single thread per netty eventgroup during testing --- .../src/main/kotlin/net/corda/nodeapi/ArtemisTcpTransport.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/node-api/src/main/kotlin/net/corda/nodeapi/ArtemisTcpTransport.kt b/node-api/src/main/kotlin/net/corda/nodeapi/ArtemisTcpTransport.kt index 9811800de0..34b5bf7784 100644 --- a/node-api/src/main/kotlin/net/corda/nodeapi/ArtemisTcpTransport.kt +++ b/node-api/src/main/kotlin/net/corda/nodeapi/ArtemisTcpTransport.kt @@ -53,7 +53,8 @@ class ArtemisTcpTransport { // It does not use AMQP messages for its own messages e.g. topology and heartbeats. // TODO further investigate how to ensure we use a well defined wire level protocol for Node to Node communications. TransportConstants.PROTOCOLS_PROP_NAME to "CORE,AMQP", - TransportConstants.USE_GLOBAL_WORKER_POOL_PROP_NAME to (nodeSerializationEnv != null) + TransportConstants.USE_GLOBAL_WORKER_POOL_PROP_NAME to (nodeSerializationEnv != null), + TransportConstants.REMOTING_THREADS_PROPNAME to (if (nodeSerializationEnv != null) -1 else 1) ) if (config != null && enableSSL) {