Hi Jun sorry this is a storm-jms issue, but I can't seem to find a user forum for storm-jms, could you point me to the right direction
thanks Ray On Fri, May 25, 2012 at 5:06 PM, Jun Rao <jun...@gmail.com> wrote: > 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 > > > -- Rgds Ray
