Marnie McCormack wrote:
I'm looking at the implementation/design work for Flow To Disk on the Java
Broker and would interested in your thoughts.
The JIRA is:
https://issues.apache.org/jira/browse/QPID-949
Please have a look and add a comment/reply to this thread if you have any
ideas.
C++-ers - is there some documentation about how the C++ broker does this ?
Not really. For a queue has been selected to use the flow to disk
policy, when a message is enqueued that would exceed the configured
limit (in message count or aggregate size) its content is released from
memory (keeping the headers in memory). When such messages are delivered
to a subscriber the data is read in again from the store.
The actual implementation is in need of some refactoring in places, but
thats the rough approach.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
