Repository: activemq Updated Branches: refs/heads/master 516c9db43 -> 6df02555f
https://issues.apache.org/jira/browse/AMQ-5680 Fix typo in getTempQueues method. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/6df02555 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/6df02555 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/6df02555 Branch: refs/heads/master Commit: 6df02555fde8bfcee003b1d248bcfcc454ad2c6f Parents: 516c9db Author: Timothy Bish <[email protected]> Authored: Wed Apr 1 09:52:33 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Wed Apr 1 09:52:33 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/activemq/broker/view/MessageBrokerView.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/6df02555/activemq-broker/src/main/java/org/apache/activemq/broker/view/MessageBrokerView.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/view/MessageBrokerView.java b/activemq-broker/src/main/java/org/apache/activemq/broker/view/MessageBrokerView.java index 5ed00f1..eeea62d 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/view/MessageBrokerView.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/view/MessageBrokerView.java @@ -36,7 +36,7 @@ import org.apache.activemq.util.LRUCache; */ public class MessageBrokerView { private final BrokerService brokerService; - private Map<ActiveMQDestination,BrokerDestinationView> destinationViewMap = new LRUCache<ActiveMQDestination, BrokerDestinationView>(); + private final Map<ActiveMQDestination,BrokerDestinationView> destinationViewMap = new LRUCache<ActiveMQDestination, BrokerDestinationView>(); /** @@ -198,7 +198,7 @@ public class MessageBrokerView { public Set<ActiveMQTempQueue> getTempQueues(){ Set<ActiveMQTempQueue> result = new HashSet<ActiveMQTempQueue>(); for (ActiveMQDestination destination:getDestinations()){ - if (destination.isTopic() && destination.isTemporary()){ + if (destination.isQueue() && destination.isTemporary()){ result.add((ActiveMQTempQueue) destination); } }
