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 <[email protected]> Authored: Tue Jun 24 14:24:39 2014 -0400 Committer: Timothy Bish <[email protected]> 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; } - }
