public class BlockingQueueManager extends BaseManager
Modifier and Type | Class and Description |
---|---|
static class |
BlockingQueueManager.GetValueKeysCallable |
BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp
BATCH_OPS_EXECUTOR_NAME, dataMemberCount, INTERNAL_OPS_EXECUTOR_NAME, localIdGen, logger, lsMembers, mapCalls, mapMembers, maxOperationLimit, maxOperationTimeout, node, qServiceThreadPacketCache, redoGiveUpThreshold, redoLogThreshold, redoWaitMillis, responsePollTimeout, systemLogService, thisAddress, thisMember
Modifier and Type | Method and Description |
---|---|
boolean |
add(String name,
Object obj,
int index) |
void |
addItemListener(String name,
ItemListener listener,
boolean includeValue) |
boolean |
addKey(String name,
Data key,
int index) |
void |
destroy(String name) |
long |
generateKey(String name,
long timeout) |
IMap |
getStorageMap(String queueName) |
Iterator |
iterate(String name) |
boolean |
offer(String name,
Object obj,
int index,
long timeout) |
boolean |
offer(String name,
Object obj,
long timeout) |
void |
offerCommit(String name,
Object key,
Data item,
int index) |
Object |
peek(String name) |
Object |
poll(String name,
long timeout) |
int |
queueSize(String name) |
Object |
remove(String name,
int index) |
boolean |
remove(String name,
Object obj) |
void |
removeItemListener(String name,
ItemListener listener) |
boolean |
removeKey(String name,
Data key) |
void |
rollbackPoll(String name,
Object key) |
Data |
set(String name,
Data key,
int index) |
Object |
set(String name,
Object newValue,
int index) |
int |
size(String name) |
void |
syncForDead(Address deadAddress) |
addRemoteCall, checkServiceThread, createRemotelyProcessablePacket, createSimpleMapEntry, enqueueAndReturn, enqueueAndWait, enqueueAndWait, getInstanceType, getMasterAddress, getMembers, getNextMemberAfter, getNextMemberAfter, getNode, getPacketProcessor, getRemoteCall, getThisAddress, handleInterruptedException, handleResponse, isActive, isLiteMember, isMaster, isMigrating, logRedo, obtainPacket, obtainPacket, registerPacketProcessor, releasePacket, removeRemoteCall, rethrowException, returnRedoResponse, returnResponse, returnResponse, send, send, sendEvents, sendOrReleasePacket, sendOrReleasePacket, sendProcessableTo, sendProcessableTo, sendProcessableToAll, sendResponse, sendResponse, sendResponseFailure
public void destroy(String name)
public void syncForDead(Address deadAddress)
public int size(String name)
public boolean offer(String name, Object obj, long timeout) throws InterruptedException
InterruptedException
public boolean offer(String name, Object obj, int index, long timeout) throws InterruptedException
InterruptedException
public Object poll(String name, long timeout) throws InterruptedException
InterruptedException
public long generateKey(String name, long timeout) throws InterruptedException
InterruptedException
public int queueSize(String name)
public void addItemListener(String name, ItemListener listener, boolean includeValue)
public void removeItemListener(String name, ItemListener listener)
Copyright © 2013 Hazelcast, Inc.. All rights reserved.