Thanks for the info, It might be good to add the prefixing option in the docs, as just reading the docs suggests automatically backward compatiability
( http://qpid.apache.org/books/0.8/Programming-In-Apache-Qpid/html/ch03s02.html#id3084791 ). I'm also looking at how to translate the old fanout address to the new one in the docs, as most of them shows topic and direct but not others. Tim On Tue, Dec 14, 2010 at 11:13 AM, Robbie Gemmell <robbie.gemm...@gmail.com>wrote: > The JMS client now defaults to using the new Address syntax developed for > the Qpid Messaging API (as used by the C++ client for example). See > http://qpid.apache.org/books/0.8/Programming-In-Apache-Qpid/html/index.html > for more details. > > Alternatively you should be able to force usage of the old Binding URL > syntax by prefixing your destinations with "BURL:" or by setting system > property qpid.dest_syntax to "BURL" > > Robbie > > > -----Original Message----- > > From: Tim Chen [mailto:t...@evri.com] > > Sent: 14 December 2010 18:38 > > To: dev@qpid.apache.org > > Subject: Qpid 0.8 problem > > > > Hi all, > > > > I'm running some problems upgrading qpid broker/client to 0.8. > > > > Currently I'm using the Qpid C++ Broker + Qpid java client, both > > updated to > > 0.8. > > > > Now when I try to create a producer like: > > > > Context _ctx = new InitialContext( properties ); > > ConnectionFactory connectionFactory = (ConnectionFactory) _ctx > > .lookup("local"); > > Connection connection = connectionFactory.createConnection(); > > Connection connection.start(); > > Destination dest = (Destination)_ctx.lookup( "queue" ); > > Session session = _connection.createSession( false, > > javax.jms.Session.AUTO_ACKNOWLEDGE ); > > Producer producer = session.createProducer( dest ); // Error here > > > > And my properties: > > > > Properties p = new Properties(); > > p.put( Context.INITIAL_CONTEXT_FACTORY, > > "org.apache.qpid.jndi.PropertiesFileInitialContextFactory" ); > > p.put( "connectionfactory.local", > > "amqp://#####:##...@clientid/localhost?brokerlist='host:port;host:port' > > " ); > > p.put( "destination.queue", "fanout://#binding_name//#queue_name" ); > > > > I'm getting a error when I try to create a producer: > > > > Exception occured while verifying > > destinationorg.apache.qpid.AMQException: > > The name 'fanout:' supplied in the address doesn't resolve to an > > exchange or > > a queue > > at > > org.apache.qpid.client.AMQSession_0_10.handleAddressBasedDestination(AM > > QSession_0_10.java:1180) > > at > > org.apache.qpid.client.BasicMessageProducer_0_10.declareDestination(Bas > > icMessageProducer_0_10.java:82) > > at > > org.apache.qpid.client.BasicMessageProducer.<init>(BasicMessageProducer > > .java:141) > > at > > org.apache.qpid.client.BasicMessageProducer_0_10.<init>(BasicMessagePro > > ducer_0_10.java:61) > > at > > org.apache.qpid.client.AMQSession_0_10.createMessageProducer(AMQSession > > _0_10.java:664) > > at > > org.apache.qpid.client.AMQSession_0_10.createMessageProducer(AMQSession > > _0_10.java:79) > > at > > org.apache.qpid.client.AMQSession$6.execute(AMQSession.java:2559) > > at > > org.apache.qpid.client.AMQSession$6.execute(AMQSession.java:2554) > > at > > org.apache.qpid.client.AMQConnectionDelegate_0_10.executeRetrySupport(A > > MQConnectionDelegate_0_10.java:286) > > 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.createProducerImpl(AMQSession.java:25 > > 52) > > at > > org.apache.qpid.client.AMQSession.createProducerImpl(AMQSession.java:25 > > 46) > > at > > org.apache.qpid.client.AMQSession.createProducer(AMQSession.java:1171) > > at > > org.apache.qpid.client.AMQSession.createProducer(AMQSession.java:120) > > > > The exact same code used to work in 0.6. I'm not sure how the > > "fanout://" > > address in destination should cause any error. > > > > I wonder if anyone knows what is wrong? > > > > Thanks, > > > > Tim > > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:dev-subscr...@qpid.apache.org > >
