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

Merge pull request #3161 from corda/CORDA-1491/aslemmer-fix-ack-race

Browse Source 
CORDA-1491: Use MessagingExecutor for deduplication ACK codepath
This commit is contained in:
Andras Slemmer 2018-05-16 13:20:25 +01:00 committed by GitHub
commit 87e955701c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt
View File

@ -420,7 +420,7 @@ class P2PMessagingClient(val config: NodeConfiguration,
deliver(cordaMessage, artemisMessage) deliver(cordaMessage, artemisMessage)
} else { } else {
log.trace { "Discard duplicate message ${cordaMessage.uniqueMessageId} for ${cordaMessage.topic}" } log.trace { "Discard duplicate message ${cordaMessage.uniqueMessageId} for ${cordaMessage.topic}" }
artemisMessage.individualAcknowledge() messagingExecutor!!.acknowledge(artemisMessage)
} }
} }
} }