You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2015/04/01 15:53:05 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5680
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 <ta...@gmail.com>
Authored: Wed Apr 1 09:52:33 2015 -0400
Committer: Timothy Bish <ta...@gmail.com>
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);
}
}