MessageProducer.send() behaviour has been created by Aidan Skinner (Jul 06, 2009).

Content:

In network terms, the semantics of the current (0.5) implementation of BasicMessageProducer_0_8 is as follows. The message is split into an AMQP ContentHeader frame and one or more ContentBody frames. These frames are then combined back into an CompositeAMQDataBlock and passed to a MinaProtocolSession.write(), which places it onto the client side outgoing MINA buffers for writing.

At this point, send() returns. It has not actually sent the message data to the broker, nor has the broker accepted that data.

--------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:commits-subscr...@qpid.apache.org

Reply via email to