I have a Java broker running inside my application and need to connect to it
using an in-vm link.
I see an InVM broker created automatically when I try to create a vm
connection url. Also I notice the protocol version setting to 0.8. And, when
I try to create a subscription using my in-vm connection, i see the
following exception.
java.lang.UnsupportedOperationException: The new addressing based sytanx is
not supported for AMQP 0-8/0-9 versions
at
org.apache.qpid.client.AMQSession_0_8.handleAddressBasedDestination(AMQSession_0_8.java:561)
at
org.apache.qpid.client.AMQSession.registerConsumer(AMQSession.java:2796)
at org.apache.qpid.client.AMQSession.access$500(AMQSession.java:120)
at org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:1989)
at org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:1955)
at
org.apache.qpid.client.AMQConnectionDelegate_8_0.executeRetrySupport(AMQConnectionDelegate_8_0.java:291)
at
org.apache.qpid.client.AMQConnection.executeRetrySupport(AMQConnection.java:766)
at
org.apache.qpid.client.failover.FailoverRetrySupport.execute(FailoverRetrySupport.java:102)
at
org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:1953)
at org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:977)
at
org.apache.qpid.client.AMQSession.createDurableSubscriber(AMQSession.java:1111)
at
org.apache.qpid.client.AMQSession.createDurableSubscriber(AMQSession.java:1026)
at
org.apache.qpid.client.AMQTopicSessionAdaptor.createDurableSubscriber(AMQTopicSessionAdaptor.java:73)
I wonder this is the proper way of consuming in-vm links. Please shed some
light.
Thanks,
Danushka
