From 3392c15c0b6e6363138240e62e257f432744c54b Mon Sep 17 00:00:00 2001
From: Andras Slemmer <andras.slemmer@r3cev.com>
Date: Wed, 16 May 2018 12:20:33 +0100
Subject: [PATCH] CORDA-1491: Use MessagingExecutor for deduplication ACK
 codepath

---
 .../net/corda/node/services/messaging/P2PMessagingClient.kt     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt b/node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt
index 3acae7898b..190cefbe60 100644
--- a/node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt
+++ b/node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt
@@ -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)
             }
         }
     }