The new Addressing syntax (the default) for the client is only supported when it is using the 0-10 protocol and the InVM connections don't currently support using 0-10 (though Andrew Kennedy is working on it at the moment). As a result InVM connections will only work using the client with the old BindingURL format at present, which can be indicated either by prefixing BURL: to your destination strings or setting qpid.dest_syntax=BURL to change the default (you can use ADDR in both cases to stipulate the newer Addressing syntax)
Robbie > -----Original Message----- > From: Danushka Menikkumbura [mailto:[email protected]] > Sent: 02 February 2011 11:32 > To: [email protected] > Subject: InVM Links > > 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(AMQ > Session_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(AM > QConnectionDelegate_8_0.java:291) > at > org.apache.qpid.client.AMQConnection.executeRetrySupport(AMQConnection. > java:766) > at > org.apache.qpid.client.failover.FailoverRetrySupport.execute(FailoverRe > trySupport.java:102) > at > org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:19 > 53) > at > org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:977) > at > org.apache.qpid.client.AMQSession.createDurableSubscriber(AMQSession.ja > va:1111) > at > org.apache.qpid.client.AMQSession.createDurableSubscriber(AMQSession.ja > va:1026) > at > org.apache.qpid.client.AMQTopicSessionAdaptor.createDurableSubscriber(A > MQTopicSessionAdaptor.java:73) > > I wonder this is the proper way of consuming in-vm links. Please shed > some > light. > > Thanks, > Danushka --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
