Ray, Is this a Kafka issue? Seems like a Storm/ActiveMQ issue.
Thanks, Jun On Fri, May 25, 2012 at 8:53 AM, Raymond Ng <raymond...@gmail.com> wrote: > 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 >
