Fix removing ended transaction id in OpenWireConnection.CommandProcessor
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9022a311 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9022a311 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9022a311 Branch: refs/heads/master Commit: 9022a311f31d0b0ef5de9faa357667965146164a Parents: 7ce2d7c Author: Ville Skyttä <[email protected]> Authored: Fri Jul 29 19:20:44 2016 +0300 Committer: Clebert Suconic <[email protected]> Committed: Fri Jul 29 15:35:25 2016 -0400 ---------------------------------------------------------------------- .../artemis/core/protocol/openwire/OpenWireConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9022a311/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java ---------------------------------------------------------------------- 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 fe05c9e..a6f00df 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(); }
