Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #1031

This commit is contained in:
JB Onofré 2023-06-16 13:57:13 +02:00
parent 7ca1a0cb43 90f96a0299
commit 52d70325ca
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
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;
}