You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Robbie Gemmell (JIRA)" <ji...@apache.org> on 2010/11/01 12:31:30 UTC
[jira] Resolved: (QPID-2321) [Java Broker] Add "conflation queue"
to Java Broker
[ https://issues.apache.org/jira/browse/QPID-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robbie Gemmell resolved QPID-2321.
----------------------------------
Resolution: Fixed
Assignee: Rob Godfrey
Resolving issue as it is completed.
> [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-subscribe@qpid.apache.org