You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by cooshal <ku...@gmail.com> on 2019/04/17 07:32:27 UTC
Invoking JMS API with JMS 2.0, ActiveMQ and osgi (karaf)
I have a scenario where I cannot switch to Artemis right now. And following
up with several posts, I understood that it gets tricky for ActiveMQ to
communicate with JMS 2.0.
Because of some limitations in Jolokia api
(http://activemq.2283324.n4.nabble.com/Is-it-possible-to-retrieve-more-than-400-messages-from-ActiveMQ-queue-via-Jolokia-API-td4750285.html),
I switched to JMS API to browse my queues. This works perfectly fine and
gave the intended results when deployed as an standalone application, as I
have included activemq-client as one of the dependencies:
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId>
<version>5.12.1</version>
<type>jar</type>
</dependency>
I tried deploying similar implementation in Karaf, by creating connection
factory as:
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"tcp://localhost:61616");
this failed because:
1. activemq-client requires JMS 1.x
2. my karaf container has JMS 2.0
Thus, I opted to use my pooled connection factory in the osgi bundle as:
e.g. my blueprint configuration; where jms/consumer is already available in
the service registry
<reference id="jmsConnectionFactory" interface="javax.jms.ConnectionFactory"
filter="(osgi.jndi.service.name=jms/consumer)" availability="mandatory" />
A fragment of my code in creating the connection is as:
brokerConnection = connectionFactory.createConnection();
session = this.createSession(brokerConnection);
brokerConnection.start();
until this point, brokerConnection and session are not null.
Queue queue = session.createQueue("test.queue");
queueBrowser = session.createBrowser(queue);
From this point on, I get a NullPointerException as:
java.lang.NullPointerException
at
org.apache.activemq.ActiveMQSession.createQueue(ActiveMQSession.java:1335)
at
org.apache.activemq.jms.pool.PooledSession.createQueue(PooledSession.java:197)
at test.mbean.getBrokerEntries(BrokerMBean.java:142)
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:497)
at sun.reflect.misc.Trampoline.invoke(MethodUtil.java:71)
at sun.reflect.GeneratedMethodAccessor27.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at sun.reflect.misc.MethodUtil.invoke(MethodUtil.java:275)
at
com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(StandardMBeanIntrospector.java:112)
at
com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(StandardMBeanIntrospector.java:46)
at
com.sun.jmx.mbeanserver.MBeanIntrospector.invokeM(MBeanIntrospector.java:237)
at com.sun.jmx.mbeanserver.PerInterface.invoke(PerInterface.java:138)
at com.sun.jmx.mbeanserver.MBeanSupport.invoke(MBeanSupport.java:252)
at javax.management.StandardMBean.invoke(StandardMBean.java:405)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:819)
at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:801)
at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:98)
at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:40)
at
org.jolokia.handler.JsonRequestHandler.handleRequest(JsonRequestHandler.java:89)
at
org.jolokia.backend.MBeanServerExecutorLocal.handleRequest(MBeanServerExecutorLocal.java:109)
at
org.jolokia.backend.MBeanServerHandler.dispatchRequest(MBeanServerHandler.java:159)
at
org.jolokia.backend.LocalRequestDispatcher.dispatchRequest(LocalRequestDispatcher.java:99)
...
I am not sure what went wrong here. Any inputs would be very helpful.
Thank you.
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
RE: Invoking JMS API with JMS 2.0, ActiveMQ and osgi (karaf)
Posted by David Martin <dm...@sis.tv>.
I have used QPID JMS as an ActiveMQ client with no issues so would recommend you persevere with it.
-----Original Message-----
From: cooshal <ku...@gmail.com>
Sent: 17 April 2019 13:51
To: users@activemq.apache.org
Subject: RE: Invoking JMS API with JMS 2.0, ActiveMQ and osgi (karaf)
I just had a quick look at QPID JMS example. Also, I tried out a simple example to browse an ActiveMQ queue. I am not able to get the intended result. I am getting an empty enumerator. Could be possible that I might have misconfigured something.
Thank you for suggesting this alternative. I need to check if this fits my needs.
--
Sent from: https://eur01.safelinks.protection.outlook.com/?url=http%3A%2F%2Factivemq.2283324.n4.nabble.com%2FActiveMQ-User-f2341805.html&data=02%7C01%7Cdmartin%40sis.tv%7C7736db3d33194815199808d6c3335743%7C629ba906d77e4dc6acf3d71375b281ea%7C0%7C1%7C636911022612583262&sdata=LRDRPkJTzJ%2BzogTahGDNzf8oTlibzPVKlYnoAPYPtEQ%3D&reserved=0
________________________________
Sports Information Services Limited. Registered Office: Whitehall Avenue, Kingston, Milton Keynes, Buckinghamshire, MK10 0AX. Company No. 4243307.
The information in this email (which includes any files transmitted with it) is confidential and is intended for the addressee only. Unauthorized recipients are required to maintain confidentiality. If you have received this email in error please notify the sender immediately, destroy any copies and delete it from your computer system.
________________________________
RE: Invoking JMS API with JMS 2.0, ActiveMQ and osgi (karaf)
Posted by cooshal <ku...@gmail.com>.
I just had a quick look at QPID JMS example. Also, I tried out a simple
example to browse an ActiveMQ queue. I am not able to get the intended
result. I am getting an empty enumerator. Could be possible that I might
have misconfigured something.
Thank you for suggesting this alternative. I need to check if this fits my
needs.
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
RE: Invoking JMS API with JMS 2.0, ActiveMQ and osgi (karaf)
Posted by David Martin <dm...@sis.tv>.
A possible option is to use the QPID JMS driver - this is a v2.0 driver - with Active MQ v5. It uses AMQP to communicate with Active MQ instead of Openwire.
-----Original Message-----
From: cooshal <ku...@gmail.com>
Sent: 17 April 2019 08:32
To: users@activemq.apache.org
Subject: Invoking JMS API with JMS 2.0, ActiveMQ and osgi (karaf)
I have a scenario where I cannot switch to Artemis right now. And following up with several posts, I understood that it gets tricky for ActiveMQ to communicate with JMS 2.0.
Because of some limitations in Jolokia api (https://eur01.safelinks.protection.outlook.com/?url=http%3A%2F%2Factivemq.2283324.n4.nabble.com%2FIs-it-possible-to-retrieve-more-than-400-messages-from-ActiveMQ-queue-via-Jolokia-API-td4750285.html&data=02%7C01%7Cdmartin%40sis.tv%7C399197d4959c4a74901608d6c3086dae%7C629ba906d77e4dc6acf3d71375b281ea%7C0%7C0%7C636910838304834479&sdata=oO%2Fikd2qhYKBx9Vy35gOVCVeDVn1mzwmZkfLFAG3zbs%3D&reserved=0),
I switched to JMS API to browse my queues. This works perfectly fine and gave the intended results when deployed as an standalone application, as I have included activemq-client as one of the dependencies:
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId>
<version>5.12.1</version>
<type>jar</type>
</dependency>
I tried deploying similar implementation in Karaf, by creating connection factory as:
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"tcp://localhost:61616");
this failed because:
1. activemq-client requires JMS 1.x
2. my karaf container has JMS 2.0
Thus, I opted to use my pooled connection factory in the osgi bundle as:
e.g. my blueprint configuration; where jms/consumer is already available in the service registry
<reference id="jmsConnectionFactory" interface="javax.jms.ConnectionFactory"
filter="(osgi.jndi.service.name=jms/consumer)" availability="mandatory" />
A fragment of my code in creating the connection is as:
brokerConnection = connectionFactory.createConnection();
session = this.createSession(brokerConnection);
brokerConnection.start();
until this point, brokerConnection and session are not null.
Queue queue = session.createQueue("test.queue");
queueBrowser = session.createBrowser(queue);
From this point on, I get a NullPointerException as:
java.lang.NullPointerException
at
org.apache.activemq.ActiveMQSession.createQueue(ActiveMQSession.java:1335)
at
org.apache.activemq.jms.pool.PooledSession.createQueue(PooledSession.java:197)
at test.mbean.getBrokerEntries(BrokerMBean.java:142)
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:497)
at sun.reflect.misc.Trampoline.invoke(MethodUtil.java:71)
at sun.reflect.GeneratedMethodAccessor27.invoke(Unknown Source) at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at sun.reflect.misc.MethodUtil.invoke(MethodUtil.java:275)
at
com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(StandardMBeanIntrospector.java:112)
at
com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(StandardMBeanIntrospector.java:46)
at
com.sun.jmx.mbeanserver.MBeanIntrospector.invokeM(MBeanIntrospector.java:237)
at com.sun.jmx.mbeanserver.PerInterface.invoke(PerInterface.java:138)
at com.sun.jmx.mbeanserver.MBeanSupport.invoke(MBeanSupport.java:252)
at javax.management.StandardMBean.invoke(StandardMBean.java:405)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:819)
at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:801)
at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:98)
at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:40)
at
org.jolokia.handler.JsonRequestHandler.handleRequest(JsonRequestHandler.java:89)
at
org.jolokia.backend.MBeanServerExecutorLocal.handleRequest(MBeanServerExecutorLocal.java:109)
at
org.jolokia.backend.MBeanServerHandler.dispatchRequest(MBeanServerHandler.java:159)
at
org.jolokia.backend.LocalRequestDispatcher.dispatchRequest(LocalRequestDispatcher.java:99)
...
I am not sure what went wrong here. Any inputs would be very helpful.
Thank you.
--
Sent from: https://eur01.safelinks.protection.outlook.com/?url=http%3A%2F%2Factivemq.2283324.n4.nabble.com%2FActiveMQ-User-f2341805.html&data=02%7C01%7Cdmartin%40sis.tv%7C399197d4959c4a74901608d6c3086dae%7C629ba906d77e4dc6acf3d71375b281ea%7C0%7C0%7C636910838304834479&sdata=fuJLxX2DJZ%2BjJdvt1WrlLkof3E9MIXfOucgLCBBpIFQ%3D&reserved=0
________________________________
Sports Information Services Limited. Registered Office: Whitehall Avenue, Kingston, Milton Keynes, Buckinghamshire, MK10 0AX. Company No. 4243307.
The information in this email (which includes any files transmitted with it) is confidential and is intended for the addressee only. Unauthorized recipients are required to maintain confidentiality. If you have received this email in error please notify the sender immediately, destroy any copies and delete it from your computer system.
________________________________