[Java Broker] Add "conflation queue" to Java Broker
---------------------------------------------------
Key: QPID-2321
URL: https://issues.apache.org/jira/browse/QPID-2321
Project: Qpid
Issue Type: New Feature
Components: Java Broker
Affects Versions: 0.7
Reporter: Rob Godfrey
Fix For: 0.7
Conflation queues replace messages with new one as they arrive if the two
messages share the same key value
A conflation queue is created if you specify a <conflationKey> in the XML
configuration; or provide a value for x-qpid-conflation-key in the arguments to
the Queue.Declare command.
A queue thus created will check incoming messages as they come in for the value
in the application headers associated with the given conflationKey. Any
message with the same conflation key value which has not yet been dequeued will
be dequeued immediately as the new message is inserted into the queue.
Using a non-acquiring consumer (i.e. browsing) one can use a conflation queue
as an LVQ which also sends updates as new values are inserted/updated.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
