Repository: activemq Updated Branches: refs/heads/activemq-5.10.x 3ab3f04f9 -> fc244f48e
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/327e19e6 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/327e19e6 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/327e19e6 Branch: refs/heads/activemq-5.10.x Commit: 327e19e6863798929178b258aab30da11dc4e6bf Parents: 3ab3f04 Author: Timothy Bish <[email protected]> Authored: Tue Jun 24 14:24:39 2014 -0400 Committer: Hadrian Zbarcea <[email protected]> Committed: Mon Dec 15 18:50:35 2014 -0500 ---------------------------------------------------------------------- .../apache/activemq/transport/stomp/StompTestSupport.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/327e19e6/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; } - }
