additional fix for fo:r https://issues.apache.org/jira/browse/AMQ-3921 make sure on selector change that we remove the subscription from the list so that the updated one gets put back in.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1359952 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2012-07-10 23:15:05 +00:00
parent 4ae6807cc2
commit 425fa47360
1 changed files with 3 additions and 0 deletions

View File

@ -220,6 +220,9 @@ public class Topic extends BaseDestination implements Task {
// Need to delete the subscription
topicStore.deleteSubscription(clientId, subscriptionName);
info = null;
synchronized (consumers) {
consumers.remove(subscription);
}
} else {
synchronized (consumers) {
if (!consumers.contains(subscription)) {