From 9022a311f31d0b0ef5de9faa357667965146164a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ville=20Skytt=C3=A4?= Date: Fri, 29 Jul 2016 19:20:44 +0300 Subject: [PATCH] Fix removing ended transaction id in OpenWireConnection.CommandProcessor --- .../artemis/core/protocol/openwire/OpenWireConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java index fe05c9ef9b..a6f00df785 100644 --- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java +++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java @@ -1195,7 +1195,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se } } else { - txMap.remove(info); + txMap.remove(txID); clearOpeartionContext(); }