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

https://issues.apache.org/jira/browse/AMQ-3459 - inactive durable subscriber view selector 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1159090 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2011-08-18 08:46:58 +00:00
parent a1b8df5605
commit 79c9f2d013
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-core/src/main/java/org/apache/activemq/broker/jmx/InactiveDurableSubscriptionView.java
View File

@ -139,4 +139,9 @@ public class InactiveDurableSubscriptionView extends DurableSubscriptionView imp
public String toString() {
return "InactiveDurableSubscriptionView: " + getClientId() + ":" + getSubscriptionName();
}
@Override
public String getSelector() {
return subscriptionInfo.getSelector();
}
}

6
activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
View File

@ -196,7 +196,8 @@ public class ManagedRegionBroker extends RegionBroker {
info.setClientId(context.getClientId());
info.setSubscriptionName(sub.getConsumerInfo().getSubscriptionName());
info.setDestination(sub.getConsumerInfo().getDestination());
addInactiveSubscription(key, info, sub);
info.setSelector(sub.getSelector());
addInactiveSubscription(key, info);
} else {
if (sub.getConsumerInfo().isDurable()) {
view = new DurableSubscriptionView(this, context.getClientId(), sub);
@ -482,7 +483,8 @@ public class ManagedRegionBroker extends RegionBroker {
info.setClientId(subscriptionKey.getClientId());
info.setSubscriptionName(subscriptionKey.getSubscriptionName());
info.setDestination(new ActiveMQTopic(view.getDestinationName()));
addInactiveSubscription(subscriptionKey, info, (brokerService.isKeepDurableSubsActive() ? view.subscription : null));
info.setSelector(view.getSelector());
addInactiveSubscription(subscriptionKey, info);
}
}
}