[AMQ-9283] Fix memory leak with STOMP unsubscribe

(cherry picked from commit 90f96a0299)
This commit is contained in:
u8675309 2023-06-12 12:10:54 -06:00 committed by JB Onofré
parent 40a13bfa21
commit c87726f2db
1 changed files with 1 additions and 0 deletions

View File

@ -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;
}