Package | Description |
---|---|
com.hazelcast.collection.impl.queue | |
com.hazelcast.collection.impl.queue.operations |
This package contains the IQueue operations
|
com.hazelcast.collection.impl.txnqueue | |
com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
Modifier and Type | Method and Description |
---|---|
QueueItem |
QueueContainer.peek()
Retrieves, but does not remove, the head of this queue, or returns
null if this queue is empty. |
QueueItem |
QueueContainer.poll()
Retrieves and removes the head of the queue (in other words, the first item), or returns
null if it is empty. |
QueueItem |
QueueContainer.txnPeek(long offerId,
String transactionId)
Retrieves, but does not remove, the head of the queue.
|
QueueItem |
QueueContainer.txnPollReserve(long reservedOfferId,
String transactionId)
Tries to obtain an item by removing the head of the
queue or removing an item previously reserved by invoking
QueueContainer.txnOfferReserve(String) with reservedOfferId . |
Modifier and Type | Method and Description |
---|---|
Map<Long,QueueItem> |
QueueContainer.getBackupMap()
Return the map containing queue items when this instance is
a backup replica.
|
Deque<QueueItem> |
QueueContainer.getItemQueue()
Returns the item queue on the partition owner.
|
Modifier and Type | Method and Description |
---|---|
int |
QueueItem.compareTo(QueueItem o) |
Constructor and Description |
---|
QueueMergeBackupOperation(String name,
Collection<QueueItem> backupItems) |
Modifier and Type | Class and Description |
---|---|
class |
TxQueueItem
Transactional Queue Item.
|
Constructor and Description |
---|
TxQueueItem(QueueItem item) |
Modifier and Type | Method and Description |
---|---|
static SplitBrainMergeTypes.QueueMergeTypes |
MergingValueFactory.createMergingValue(SerializationService serializationService,
Queue<QueueItem> items) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.