ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-06-09 10:51:43 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Merge pull request #47 from corda/mnesbit-fix-corruption-in-memory-network-tests

Browse Source 
Fix errors with multi-thread InMemoryMessagingNetwork
This commit is contained in:
Matthew Nesbit 2016-12-12 09:15:52 +00:00 committed by GitHub
commit fc69624f41
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test-utils/src/main/kotlin/net/corda/testing/node/InMemoryMessagingNetwork.kt
View File

@ -374,7 +374,7 @@ class InMemoryMessagingNetwork(val sendManuallyPumped: Boolean) : SingletonSeria
private fun MessageTransfer.toReceivedMessage() = object : ReceivedMessage { private fun MessageTransfer.toReceivedMessage() = object : ReceivedMessage {
override val topicSession: TopicSession get() = message.topicSession 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 peer: X500Name get() = X509Utilities.getDevX509Name(sender.description)
override val debugTimestamp: Instant get() = message.debugTimestamp override val debugTimestamp: Instant get() = message.debugTimestamp
override val uniqueMessageId: UUID get() = message.uniqueMessageId override val uniqueMessageId: UUID get() = message.uniqueMessageId