ARTEMIS-953 fix examples
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/150a5916 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/150a5916 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/150a5916 Branch: refs/heads/master Commit: 150a5916cd120104cfd35738c48be64b1d7ac5ad Parents: ff3e75d Author: Justin Bertram <[email protected]> Authored: Mon Feb 13 09:51:31 2017 -0600 Committer: Justin Bertram <[email protected]> Committed: Mon Feb 13 09:51:31 2017 -0600 ---------------------------------------------------------------------- .../java/org/apache/activemq/artemis/jms/example/JMXExample.java | 4 +++- .../activemq/artemis/jms/example/MessageCounterExample.java | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/150a5916/examples/features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java ---------------------------------------------------------------------- diff --git a/examples/features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java b/examples/features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java index dfca508..73658ed 100644 --- a/examples/features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java +++ b/examples/features/standard/jmx/src/main/java/org/apache/activemq/artemis/jms/example/JMXExample.java @@ -33,6 +33,8 @@ import javax.management.remote.JMXServiceURL; import javax.naming.InitialContext; import java.util.HashMap; +import org.apache.activemq.artemis.api.core.RoutingType; +import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.api.core.management.QueueControl; import org.apache.activemq.artemis.jms.client.ActiveMQTextMessage; @@ -74,7 +76,7 @@ public class JMXExample { producer.send(message); // Step 9. Retrieve the ObjectName of the queue. This is used to identify the server resources to manage - ObjectName on = ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(queue.getQueueName()); + ObjectName on = ObjectNameBuilder.DEFAULT.getQueueObjectName(SimpleString.toSimpleString(queue.getQueueName()), SimpleString.toSimpleString(queue.getQueueName()), RoutingType.ANYCAST); // Step 10. Create JMX Connector to connect to the server's MBeanServer JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(JMXExample.JMX_URL), new HashMap()); http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/150a5916/examples/features/standard/message-counters/src/main/java/org/apache/activemq/artemis/jms/example/MessageCounterExample.java ---------------------------------------------------------------------- diff --git a/examples/features/standard/message-counters/src/main/java/org/apache/activemq/artemis/jms/example/MessageCounterExample.java b/examples/features/standard/message-counters/src/main/java/org/apache/activemq/artemis/jms/example/MessageCounterExample.java index f227343..f3b2dbe 100644 --- a/examples/features/standard/message-counters/src/main/java/org/apache/activemq/artemis/jms/example/MessageCounterExample.java +++ b/examples/features/standard/message-counters/src/main/java/org/apache/activemq/artemis/jms/example/MessageCounterExample.java @@ -33,6 +33,8 @@ import javax.management.remote.JMXServiceURL; import javax.naming.InitialContext; import java.util.HashMap; +import org.apache.activemq.artemis.api.core.RoutingType; +import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.management.MessageCounterInfo; import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.api.core.management.QueueControl; @@ -72,7 +74,7 @@ public class MessageCounterExample { Thread.sleep(3000); // Step 7. Use JMX to retrieve the message counters using the JMSQueueControl - ObjectName on = ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(queue.getQueueName()); + ObjectName on = ObjectNameBuilder.DEFAULT.getQueueObjectName(SimpleString.toSimpleString(queue.getQueueName()), SimpleString.toSimpleString(queue.getQueueName()), RoutingType.ANYCAST); JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(JMX_URL), new HashMap<String, Object>()); MBeanServerConnection mbsc = connector.getMBeanServerConnection(); QueueControl queueControl = MBeanServerInvocationHandler.newProxyInstance(mbsc, on, QueueControl.class, false);
