activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: JAVA ActiveMQ JMX browse messages on Topic
Date Sat, 19 Aug 2017 02:01:30 GMT
You can browse queues, but not topics.

Tim

On Aug 18, 2017 12:15 PM, "Hitesh" <hitesh.hotchandani@contentsphere.com>
wrote:

> Hi all,
>
> The following question is for ActiveMQ 5.13.
>
> I have 2 durable subscribers listening to a topic, lets say ExampleTopic.
> I need to delete all the messages on that topic when a particular event
> occurs. I tried to find the jolokia apis to do the same but couldn't find
> any.
> So I've decided to use JMX Mbeans to browse the messages and delete them
> one
> by one.
>
> A simple java program which will connect to JMXService and fetch the
> information for all the messages.
>
> JMXServiceURL url = new
> JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");
> JMXConnector jmxc = JMXConnectorFactory.connect(url);
> MBeanServerConnection conn = jmxc.getMBeanServerConnection();
> ObjectName mbeanName = new
> ObjectName("org.apache.activemq:type=Broker,brokerName=localhost");
> TopicViewMBean bean = MBeanServerInvocationHandler.newProxyInstance(conn,
> mbeanName, TopicViewMBean.class, true);
> List list = bean.browseMessages();
>
> However this throws the following exception:
>
> java.lang.reflect.UndeclaredThrowableException
>         at com.sun.proxy.$Proxy0.browseMessages(Unknown Source)
>         at com.exportstaging.main.Test.main(Test.java:25)
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:
> 62)
>         at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(
> DelegatingMethodAccessorImpl.java:43)
>         at java.lang.reflect.Method.invoke(Method.java:498)
>         at com.intellij.rt.execution.application.AppMain.main(
> AppMain.java:147)
> Caused by: javax.management.ReflectionException: No such operation:
> browseMessages
>
>
> I tried to find the web for this, but couldn't find any solution.
>
> Can someone help me fix this.
>
> Thanks in advance
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/JAVA-ActiveMQ-JMX-browse-messages-on-Topic-tp4729813.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message