Hello,
I started trying to use Qpid JMS in our services. I’ve been using the
following source code as an example:
https://github.com/apache/qpid-jms/tree/0.29.0/qpid-jms-examples.
I’m using ActiveMQ 5.13.4 as the message broker which is configured to
use the AMQP transport connector:
2018-02-07 13:47:44,469 | INFO | Listening for connections at:
amqp://msgs:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600
| org.apache.activemq.transport.TransportServerThreadSupport | main
However, when trying to connect to it using Qpid JMS and the following
Connection Factory 'amqp://msgs:5672' I’m getting the following
exception at the moment:
Caused by: java.io.IOException: Provider scheme NOT recognized: [amqp]
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:124)
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:99)
at
org.apache.qpid.jms.provider.ProviderFactory.create(ProviderFactory.java:70)
at
org.apache.qpid.jms.JmsConnectionFactory.createProvider(JmsConnectionFactory.java:328)
at
org.apache.qpid.jms.JmsConnectionFactory.createQueueConnection(JmsConnectionFactory.java:227)
... 38 more
Caused by: java.lang.IllegalArgumentException: Not all provider
options could be set on the found factory. Check the options are
spelled correctly. Given parameters=[{providerScheme=amqp,
transportScheme=tcp}]. This provider instance cannot be started.
at
org.apache.qpid.jms.util.FactoryFinder$StandaloneObjectFactory.create(FactoryFinder.java:191)
at
org.apache.qpid.jms.util.FactoryFinder.newInstance(FactoryFinder.java:129)
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:122)
... 42 more
Changing the Connection Factory to
'amqp:///test?brokerlist='tcp://msgs:5672'' I'm getting the same exception:
Caused by: java.io.IOException: Provider scheme NOT recognized: [amqp]
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:124)
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:99)
at
org.apache.qpid.jms.provider.ProviderFactory.create(ProviderFactory.java:70)
at
org.apache.qpid.jms.JmsConnectionFactory.createProvider(JmsConnectionFactory.java:328)
at
org.apache.qpid.jms.JmsConnectionFactory.createQueueConnection(JmsConnectionFactory.java:227)
... 38 more
Caused by: java.lang.IllegalArgumentException: Not all provider
options could be set on the found factory. Check the options are
spelled correctly. Given parameters=[{providerScheme=amqp,
transportScheme=tcp}]. This provider instance cannot be started.
at
org.apache.qpid.jms.util.FactoryFinder$StandaloneObjectFactory.create(FactoryFinder.java:191)
at
org.apache.qpid.jms.util.FactoryFinder.newInstance(FactoryFinder.java:129)
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:122)
... 42 more
Changing the amqp:// scheme to tcp:// scheme gives the following exception:
Caused by: java.io.IOException: Provider scheme NOT recognized: [tcp]
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:124)
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:99)
at
org.apache.qpid.jms.provider.ProviderFactory.create(ProviderFactory.java:70)
at
org.apache.qpid.jms.JmsConnectionFactory.createProvider(JmsConnectionFactory.java:328)
at
org.apache.qpid.jms.JmsConnectionFactory.createQueueConnection(JmsConnectionFactory.java:227)
... 38 more
Caused by: org.apache.qpid.jms.util.ResourceNotFoundException: Could
not find factory resource:
META-INF/services/org/apache/qpid/jms/provider/tcp
at
org.apache.qpid.jms.util.FactoryFinder$StandaloneObjectFactory.loadProperties(FactoryFinder.java:230)
at
org.apache.qpid.jms.util.FactoryFinder$StandaloneObjectFactory.create(FactoryFinder.java:171)
at
org.apache.qpid.jms.util.FactoryFinder.newInstance(FactoryFinder.java:129)
at
org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:122)
... 42 more
How can I get a working connection to ActiveMQ's AMQP using Qpid JMS?
Thanks,
Jeroen...
