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 a879af3b56..753e9ff330 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
@@ -294,9 +294,11 @@ class P2PMessagingClient(config: NodeConfiguration,
                     // processing a message but if so, it'll be parked waiting for us to count down the latch, so
                     // the session itself is still around and we can still ack messages as a result.
                     override fun acknowledge() {
-                        state.locked {
-                            artemisMessage.individualAcknowledge()
-                            artemis.started!!.session.commit()
+                        messagingExecutor.fetchFrom {
+                            state.locked {
+                                artemisMessage.individualAcknowledge()
+                                artemis.started!!.session.commit()
+                            }
                         }
                     }
                 }