I've been working with the Python QPID client and grok the
'session.incoming' function, which returns a queue that I can read
messages from. Pretty simple.

Moving over to the Java client, and it seems I have to use a session
listener to accomplish the same thing. This means I need to use my own
queue (e.g. java.util.concurrent.BlockingQueue) and feed it with the
listener.

Am I correct in this? The Java client uses a fairly different approach
from Python to reading local queues in this respect?

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:[email protected]

Reply via email to