diff --git a/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/LoopbackBridgeManager.kt b/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/LoopbackBridgeManager.kt index 2dd9f8bff0..ce68cfbd96 100644 --- a/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/LoopbackBridgeManager.kt +++ b/node-api/src/main/kotlin/net/corda/nodeapi/internal/bridging/LoopbackBridgeManager.kt @@ -136,7 +136,7 @@ class LoopbackBridgeManager(keyStore: CertificateStore, private fun clientArtemisMessageHandler(artemisMessage: ClientMessage) { logDebugWithMDC { "Loopback Send to ${legalNames.first()} uuid: ${artemisMessage.getObjectProperty(MESSAGE_ID_KEY)}" } val peerInbox = translateLocalQueueToInboxAddress(queueName) - producer?.send(SimpleString(peerInbox), artemisMessage) { artemisMessage.individualAcknowledge() } + producer?.send(SimpleString.of(peerInbox), artemisMessage) { artemisMessage.individualAcknowledge() } bridgeMetricsService?.let { metricsService -> val properties = ArtemisMessagingComponent.Companion.P2PMessagingHeaders.whitelistedHeaders.mapNotNull { key -> if (artemisMessage.containsProperty(key)) {