[
https://issues.apache.org/jira/browse/QPID-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ernest Allen updated QPID-4591:
-------------------------------
Attachment: bz691411.patch1
Adds mechanism to store and retrieve a queue level sequence number in message
properties.
To enable storing of sequence numbers, declare queue with argument
qpid.queue_msg_sequence set to user defined key.
To retrieve the sequence number from a message, get the message properties
using the same user defined key.
std::string addr("my-queue;"
" {create:always, delete:always,"
" node: {type: queue, x-declare: {arguments:"
" {qpid.queue_msg_sequence:my_seq_key, qpid.policy_type:ring,
qpid.max_count:4}}}}");
Sender sender = session.createSender(addr);
...
Receiver receiver = session.createReceiver("my-queue");
Message response = receiver.fetch();
uint32_t seqNo = response.getProperties()["my_seq_key"];
if (seqNo - lastSeqNo > 1)
//Gap detected. Messages were overwritten
...
> mechanism to detect when messages are overwritten in ring-type queues
> ---------------------------------------------------------------------
>
> Key: QPID-4591
> URL: https://issues.apache.org/jira/browse/QPID-4591
> Project: Qpid
> Issue Type: New Feature
> Components: C++ Broker
> Affects Versions: 0.18
> Reporter: Ernest Allen
> Fix For: Future
>
> Attachments: bz691411.patch1
>
>
> A way to determine when a ring queue is full and old messages are being
> deleted. Also need a way to determine when the ring queue is no longer full.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
