ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2024-12-19 04:57:58 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

CORDA-1491: Use MessagingExecutor for deduplication ACK codepath

Browse Source
This commit is contained in:
Andras Slemmer 2018-05-16 12:20:33 +01:00
parent b06738b371
commit 3392c15c0b
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)
} else {
log.trace { "Discard duplicate message ${cordaMessage.uniqueMessageId} for ${cordaMessage.topic}" }
artemisMessage.individualAcknowledge()
messagingExecutor!!.acknowledge(artemisMessage)
}
}
}