On 07/08/2011 02:01 PM, Gordon Sim wrote:
If I use the first two types of configuration mentioned in the example
at https://cwiki.apache.org/qpid/how-to-use-jndi.html (i.e. queue.xyz =
or topic.xyz = ) then the 0-9-1 path incorrectly issues
exchange-declares without the passive flag set (for amq.direct or
amq.topic respectively).
Ok, with the following patch applied I can get past this particular
issue. If can then send a message and receive it through a MessageListener.
The 'pull' style receive() call doesn't appear to work. It does
correctly result in a channel.flow, but the broker doesn't seem to
respond by sending any message.
I'm still interested in getting ideas on how to get the destination
style jndi properties working with BURL.
Index: client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java
===================================================================
--- client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java (revision 1141888)
+++ client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java (working copy)
@@ -58,10 +58,10 @@
ExchangeDeclareBody body = getSession().getMethodRegistry().createExchangeDeclareBody(_session.getTicket(),
destination.getExchangeName(),
destination.getExchangeClass(),
+ destination.getExchangeName().toString().startsWith("amq."),
false,
false,
false,
- false,
true,
null);
// Declare the exchange
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
