Garrett Smith wrote:
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.
If you use JMS you can create a MessageConsumer and use the receive()
method which does a similar sort of thing.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]