mirror of https://github.com/apache/activemq.git
applied patch for http://issues.apache.org/activemq/browse/AMQ-1077
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499032 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
28a7312f2e
commit
1a448be825
|
@ -377,7 +377,8 @@ public class ProtocolConverter {
|
||||||
(destination!=null && destination.equals(sub.getDestination()) )
|
(destination!=null && destination.equals(sub.getDestination()) )
|
||||||
) {
|
) {
|
||||||
sendToActiveMQ(sub.getConsumerInfo().createRemoveCommand(), createResponseHandler(command));
|
sendToActiveMQ(sub.getConsumerInfo().createRemoveCommand(), createResponseHandler(command));
|
||||||
return;
|
iter.remove();
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue