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 2014/06/24 20:24:44 UTC
git commit: Fix the getProxyToTopic method.
Repository: activemq
Updated Branches:
refs/heads/trunk d9b03acff -> 0fdd4611a
Fix the getProxyToTopic method.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/0fdd4611
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/0fdd4611
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/0fdd4611
Branch: refs/heads/trunk
Commit: 0fdd4611a0918fadadc9e6ecf594c9d97b8f5ca3
Parents: d9b03ac
Author: Timothy Bish <ta...@gmail.com>
Authored: Tue Jun 24 14:24:39 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Tue Jun 24 14:24:39 2014 -0400
----------------------------------------------------------------------
.../apache/activemq/transport/stomp/StompTestSupport.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/0fdd4611/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java
----------------------------------------------------------------------
diff --git a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java
index 5d6183b..3cf1356 100644
--- a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java
+++ b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java
@@ -35,6 +35,7 @@ import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.TransportConnector;
import org.apache.activemq.broker.jmx.BrokerViewMBean;
import org.apache.activemq.broker.jmx.QueueViewMBean;
+import org.apache.activemq.broker.jmx.TopicViewMBean;
import org.apache.activemq.filter.DestinationMapEntry;
import org.apache.activemq.security.AuthenticationUser;
import org.apache.activemq.security.AuthorizationEntry;
@@ -317,11 +318,10 @@ public class StompTestSupport {
return proxy;
}
- protected QueueViewMBean getProxyToTopic(String name) throws MalformedObjectNameException, JMSException {
- ObjectName queueViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Topic,destinationName="+name);
- QueueViewMBean proxy = (QueueViewMBean) brokerService.getManagementContext()
- .newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true);
+ protected TopicViewMBean getProxyToTopic(String name) throws MalformedObjectNameException, JMSException {
+ ObjectName topicViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Topic,destinationName="+name);
+ TopicViewMBean proxy = (TopicViewMBean) brokerService.getManagementContext()
+ .newProxyInstance(topicViewMBeanName, TopicViewMBean.class, true);
return proxy;
}
-
}