Hi
I've been trying to use the storm-jms example to talk to QPID but having
problem configuring it with the right connectionFactory
I need to pass the following QPID connection string
amqp://test:t...@192.168.xxx.xxx
//?brokerlist='tcp://192.168.xxx.xxx:nnnn'
to the brokerURL attribute in the spring config below
<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>
<amq:queue id="notificationQueue"
physicalName="backtype.storm.contrib.example.queue" />
<amq:topic id="notificationTopic"
physicalName="backtype.storm.contrib.example.topic" />
<amq:connectionFactory id="jmsConnectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
but gets the following error
javax.jms.JMSException: Could not create Transport. Reason:
java.io.IOException: Transport scheme NOT recognized: [amqp]
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:35)
at
org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:254)
at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:267)
at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:239)
at
org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:185)
at
com.detica.treidan.storm.utils.SpringJmsProvider.testConnection(SpringJmsProvider.java:92)
at
com.detica.treidan.storm.utils.SpringJmsProvider.<init>(SpringJmsProvider.java:59)
at
com.detica.treidan.storm.demo.topologies.RollingTopIpPairsKafka.main(RollingTopIpPairsKafka.java:64)
Caused by: java.io.IOException: Transport scheme NOT recognized: [amqp]
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)
at
org.apache.activemq.transport.TransportFactory.findTransportFactory(TransportFactory.java:204)
at
org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:79)
at
org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:252)
... 6 more
Caused by: java.io.IOException: Could not find factory class for resource:
META-INF/services/org/apache/activemq/transport/amqp
at
org.apache.activemq.util.FactoryFinder$StandaloneObjectFactory.loadProperties(FactoryFinder.java:96)
at
org.apache.activemq.util.FactoryFinder$StandaloneObjectFactory.create(FactoryFinder.java:58)
at
org.apache.activemq.util.FactoryFinder.newInstance(FactoryFinder.java:146)
at
org.apache.activemq.transport.TransportFactory.findTransportFactory(TransportFactory.java:201)
... 8 more
can someone advice please?
--
Rgds
Ray
