Hi all,
I am trying to connect MB (2.2.0) as producer and CEP (4.0.0) as consumer
using input adapters. I am getting following error continously once i have
connected the CEP with MB.
ERROR - {NativeWorkerPool} Uncaught exception
java.lang.UnsupportedOperationException: The new addressing based sytanx is
not supported for AMQP 0-8/0-9 versions
at
org.wso2.andes.client.AMQSession_0_8.handleAddressBasedDestination(AMQSession_0_8.java:577)
at org.wso2.andes.client.AMQSession.registerConsumer(AMQSession.java:2868)
at org.wso2.andes.client.AMQSession.access$500(AMQSession.java:109)
at org.wso2.andes.client.AMQSession$5.execute(AMQSession.java:2061)
at org.wso2.andes.client.AMQSession$5.execute(AMQSession.java:2027)
at
org.wso2.andes.client.AMQConnectionDelegate_8_0.executeRetrySupport(AMQConnectionDelegate_8_0.java:315)
at
org.wso2.andes.client.AMQConnection.executeRetrySupport(AMQConnection.java:621)
at
org.wso2.andes.client.failover.FailoverRetrySupport.execute(FailoverRetrySupport.java:102)
at org.wso2.andes.client.AMQSession.createConsumerImpl(AMQSession.java:2025)
at org.wso2.andes.client.AMQSession.createConsumer(AMQSession.java:1028)
at
org.wso2.carbon.event.input.adaptor.jms.internal.util.JMSUtils.createConsumer(JMSUtils.java:472)
at
org.wso2.carbon.event.input.adaptor.jms.internal.util.JMSTaskManager$MessageListenerTask.createConsumer(JMSTaskManager.java:982)
at
org.wso2.carbon.event.input.adaptor.jms.internal.util.JMSTaskManager$MessageListenerTask.getMessageConsumer(JMSTaskManager.java:850)
at
org.wso2.carbon.event.input.adaptor.jms.internal.util.JMSTaskManager$MessageListenerTask.receiveMessage(JMSTaskManager.java:599)
at
org.wso2.carbon.event.input.adaptor.jms.internal.util.JMSTaskManager$MessageListenerTask.run(JMSTaskManager.java:520)
at
org.apache.axis2.transport.base.threads.NativeWorkerPool$1.run(NativeWorkerPool.java:172)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:695)
Following are CEP jndi properties
# register some connection factories
# connectionfactory.[jndiname] = [ConnectionURL]
connectionfactory.TopicConnectionFactory = amqp://admin:admin@clientID
/carbon?brokerlist='tcp://localhost:5674'
connectionfactory.QueueConnectionFactory = amqp://admin:admin@clientID
/carbon?brokerlist='tcp://localhost:5674''
# register some queues in JNDI using the form
# queue.[jndiName] = [physicalName]
queue.MyQueue = example.MyQueue
# register some topics in JNDI using the form
# topic.[jndiName] = [physicalName]
topic.MyTopic = example.MyTopic
This the CEP input adapter
<inputEventAdaptor name="jmsInputAdapter" statistics="disable"
trace="disable" type="jms" xmlns="
http://wso2.org/carbon/eventadaptormanager";>
<property
name="java.naming.provider.url">repository/conf/jndi.properties</property>
<property
name="java.naming.factory.initial">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</property>
<property
name="transport.jms.ConnectionFactoryJNDIName">TopicConnectionFactory</property>
<property name="transport.jms.DestinationType">topic</property>
</inputEventAdaptor>
Is it causing due to mismatching of AMQP version?
--
*Tharik Kanaka* | Associate Software Engineer
WSO2, Inc |#20, Palm Grove, Colombo 03, Sri Lanka
Email: tha...@wso2.com | Web: www.wso2.com
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
