mirror of https://github.com/apache/activemq.git
[AMQ-9283] Fix memory leak with STOMP unsubscribe
This commit is contained in:
parent
7ca1a0cb43
commit
90f96a0299
|
@ -718,6 +718,7 @@ public class ProtocolConverter {
|
|||
if (subscriptionId != null) {
|
||||
StompSubscription sub = this.subscriptions.remove(subscriptionId);
|
||||
if (sub != null) {
|
||||
subscriptionsByConsumerId.remove(sub.getConsumerInfo().getConsumerId());
|
||||
sendToActiveMQ(sub.getConsumerInfo().createRemoveCommand(), createResponseHandler(command));
|
||||
return;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue