[activemq-artemis] branch master updated: ARTEMIS-2788 clear openwire producer exchange, created on send, on producer close event

[gt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gtully pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 56dbd91  ARTEMIS-2788 clear openwire producer exchange, created on send, on producer close event
     new d0eabde  Merge pull request #3170 from gtully/ARTEMIS-2788
56dbd91 is described below

commit 56dbd91263b119d05ae34a906f2cbed7829f6661
Author: gtully <ga...@gmail.com>
AuthorDate: Fri Jun 5 10:22:44 2020 +0100

    ARTEMIS-2788 clear openwire producer exchange, created on send, on producer close event
---
 .../activemq/artemis/core/protocol/openwire/OpenWireConnection.java    | 3 +++
 1 file changed, 3 insertions(+)

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 970271c..f008009 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
@@ -1211,6 +1211,9 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
                ss.removeProducer(id);
             }
          }
+         synchronized (producerExchanges) {
+            producerExchanges.remove(id);
+         }
          return null;
       }