diff --git a/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/BridgeControlListener.kt b/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/BridgeControlListener.kt index 995ce01eba..c1fb05a20a 100644 --- a/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/BridgeControlListener.kt +++ b/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/BridgeControlListener.kt @@ -55,6 +55,7 @@ class BridgeControlListener(val config: MutualSslConfiguration, } catch (ex: Exception) { log.error("Unable to process bridge control message", ex) } + msg.acknowledge() } val startupMessage = BridgeControl.BridgeToNodeSnapshotRequest(bridgeId).serialize(context = SerializationDefaults.P2P_CONTEXT).bytes val bridgeRequest = artemisSession.createMessage(false)