[ https://issues.apache.org/jira/browse/QPID-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12968461#action_12968461 ]
Robbie Gemmell commented on QPID-2321: -------------------------------------- The trunk additions for this JIRA were merged onto trunk with the work committed on QPID-2379. > [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 > Assignee: 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:dev-subscr...@qpid.apache.org