diff --git a/test-utils/src/main/kotlin/net/corda/testing/node/InMemoryMessagingNetwork.kt b/test-utils/src/main/kotlin/net/corda/testing/node/InMemoryMessagingNetwork.kt index c38c29fe2f..bcc29d4581 100644 --- a/test-utils/src/main/kotlin/net/corda/testing/node/InMemoryMessagingNetwork.kt +++ b/test-utils/src/main/kotlin/net/corda/testing/node/InMemoryMessagingNetwork.kt @@ -374,7 +374,7 @@ class InMemoryMessagingNetwork(val sendManuallyPumped: Boolean) : SingletonSeria private fun MessageTransfer.toReceivedMessage() = object : ReceivedMessage { override val topicSession: TopicSession get() = message.topicSession - override val data: ByteArray get() = message.data + override val data: ByteArray get() = message.data.copyOf() // Kryo messes with the buffer so give each client a unique copy override val peer: X500Name get() = X509Utilities.getDevX509Name(sender.description) override val debugTimestamp: Instant get() = message.debugTimestamp override val uniqueMessageId: UUID get() = message.uniqueMessageId