public class QueueContainer extends Object implements IdentifiedDataSerializable
Constructor and Description |
---|
QueueContainer(String name) |
QueueContainer(String name,
QueueConfig config,
NodeEngine nodeEngine,
QueueService service) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
addAll(Collection<Data> dataList) |
void |
addAllBackup(Map<Long,Data> dataMap) |
int |
backupSize() |
void |
cancelEvictionIfExists() |
Map<Long,Data> |
clear() |
void |
clearBackup(Set<Long> itemIdSet) |
Map<Long,Data> |
compareAndRemove(Collection<Data> dataList,
boolean retain)
This method triggers store load
|
void |
compareAndRemoveBackup(Set<Long> itemIdSet) |
boolean |
contains(Collection<Data> dataSet)
This method does not trigger store load.
|
void |
destroy() |
Map<Long,Data> |
drain(int maxSize) |
void |
drainFromBackup(Set<Long> itemIdSet) |
List<Data> |
getAsDataList()
This method triggers store load.
|
QueueConfig |
getConfig() |
Data |
getDataFromMap(long itemId) |
int |
getFactoryId() |
int |
getId() |
QueueWaitNotifyKey |
getOfferWaitNotifyKey() |
QueueWaitNotifyKey |
getPollWaitNotifyKey() |
boolean |
hasEnoughCapacity() |
boolean |
hasEnoughCapacity(int delta) |
void |
init(boolean fromBackup) |
boolean |
isEvictable() |
long |
offer(Data data) |
void |
offerBackup(Data data,
long itemId) |
QueueItem |
peek() |
QueueItem |
poll() |
void |
pollBackup(long itemId) |
void |
readData(ObjectDataInput in) |
long |
remove(Data data)
iterates all items, checks equality with data
This method does not trigger store load.
|
void |
removeBackup(long itemId) |
void |
rollbackTransaction(String transactionId) |
void |
setConfig(QueueConfig config,
NodeEngine nodeEngine,
QueueService service) |
void |
setStats(LocalQueueStatsImpl stats) |
int |
size() |
boolean |
txnCommitOffer(long itemId,
Data data,
boolean backup) |
Data |
txnCommitPoll(long itemId) |
Data |
txnCommitPollBackup(long itemId) |
boolean |
txnEnsureReserve(long itemId) |
void |
txnOfferBackupReserve(long itemId,
String transactionId) |
long |
txnOfferReserve(String transactionId) |
QueueItem |
txnPeek(long offerId,
String transactionId) |
boolean |
txnPollBackupReserve(long itemId,
String transactionId) |
QueueItem |
txnPollReserve(long reservedOfferId,
String transactionId) |
boolean |
txnRollbackOffer(long itemId) |
boolean |
txnRollbackOfferBackup(long itemId) |
boolean |
txnRollbackPoll(long itemId,
boolean backup) |
void |
writeData(ObjectDataOutput out) |
public QueueContainer(String name)
public QueueContainer(String name, QueueConfig config, NodeEngine nodeEngine, QueueService service) throws Exception
Exception
public void init(boolean fromBackup)
public boolean txnEnsureReserve(long itemId)
public boolean txnPollBackupReserve(long itemId, String transactionId)
public Data txnCommitPoll(long itemId)
public Data txnCommitPollBackup(long itemId)
public boolean txnRollbackPoll(long itemId, boolean backup)
public long txnOfferReserve(String transactionId)
public void txnOfferBackupReserve(long itemId, String transactionId)
public boolean txnCommitOffer(long itemId, Data data, boolean backup)
public boolean txnRollbackOffer(long itemId)
public boolean txnRollbackOfferBackup(long itemId)
public long offer(Data data)
public void offerBackup(Data data, long itemId)
public Map<Long,Data> addAll(Collection<Data> dataList)
public QueueItem peek()
public QueueItem poll()
public void pollBackup(long itemId)
public int size()
public int backupSize()
public long remove(Data data)
public void removeBackup(long itemId)
public boolean contains(Collection<Data> dataSet)
public Map<Long,Data> compareAndRemove(Collection<Data> dataList, boolean retain)
public boolean hasEnoughCapacity()
public boolean hasEnoughCapacity(int delta)
public Data getDataFromMap(long itemId)
public void setConfig(QueueConfig config, NodeEngine nodeEngine, QueueService service)
public QueueWaitNotifyKey getPollWaitNotifyKey()
public QueueWaitNotifyKey getOfferWaitNotifyKey()
public QueueConfig getConfig()
public void setStats(LocalQueueStatsImpl stats)
public void cancelEvictionIfExists()
public boolean isEvictable()
public void rollbackTransaction(String transactionId)
public void writeData(ObjectDataOutput out) throws IOException
writeData
in interface DataSerializable
IOException
public void readData(ObjectDataInput in) throws IOException
readData
in interface DataSerializable
IOException
public void destroy()
public int getFactoryId()
getFactoryId
in interface IdentifiedDataSerializable
public int getId()
getId
in interface IdentifiedDataSerializable
Copyright © 2014 Hazelcast, Inc.. All rights reserved.