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
