Advances the specified subscriptions to the next entry in the linked list
Advances the specified subscriptions to the next entry in the linked list
Combines this queue entry with the next queue entry.
Gets number of messages that this entry represents
Gets number of messages that this entry represents
Attempts to dispatch the current entry to the subscriptions position at the entry.
Attempts to dispatch the current entry to the subscriptions position at the entry.
When the entry expires or 0 if it does not expire.
When the entry expires or 0 if it does not expire.
Is the entry acquired by a subscription.
Is the entry acquired by a subscription.
Retuns a string label used to describe this state.
Retuns a string label used to describe this state.
Gets the message key for the entry.
Gets the message key for the entry.
Called to increment the redelivery counter
Called to increment the redelivery counter
When the entry expires or 0 if it does not expire.
When the entry expires or 0 if it does not expire.
Removes the entry from the queue's linked list of entries.
Removes the entry from the queue's linked list of entries. This gets called as a result of an acquired ack.
Gets the size of this entry in bytes.
Gets the size of this entry in bytes. The head and tail entries always return 0.
Triggers the entry to get swapped in if it's not already swapped in.
Triggers the entry to get swapped in if it's not already swapped in.
Triggers the entry to get swapped out if it's not already swapped.
Triggers the entry to get swapped out if it's not already swapped.
A SwappedRange state is assigned entry is used to represent a rage of swapped entries.
Even entries that are Swapped can us a significant amount of memory if the queue is holding thousands of them. Multiple entries in the swapped state can be combined into a single entry in the SwappedRange state thereby conserving even more memory. A SwappedRange entry only tracks the first, and last sequnce ids of the range. When the entry needs to be loaded from the range it replaces the swapped range entry with all the swapped entries by querying the store of all the message keys for the entries in the range.