com.hazelcast.impl

Class BlockingQueueManager

java.lang.Object

com.hazelcast.impl.BaseManager

com.hazelcast.impl.BlockingQueueManager

public class BlockingQueueManager
extends BaseManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockingQueueManager.GetValueKeysCallable

Nested classes/interfaces inherited from class com.hazelcast.impl.BaseManager

BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp

Field Summary

Fields inherited from class com.hazelcast.impl.BaseManager

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

Method Summary

Methods

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)

Methods inherited from class com.hazelcast.impl.BaseManager

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

destroy

public void destroy(String name)

syncForDead

public void syncForDead(Address deadAddress)

size

public int size(String name)

remove

public boolean remove(String name,
             Object obj)

add

public boolean add(String name,
          Object obj,
          int index)

offer

public boolean offer(String name,
            Object obj,
            long timeout)
              throws InterruptedException

Throws:

InterruptedException

offer

public boolean offer(String name,
            Object obj,
            int index,
            long timeout)
              throws InterruptedException

Throws:

InterruptedException

set

public Object set(String name,
         Object newValue,
         int index)

remove

public Object remove(String name,
            int index)

offerCommit

public void offerCommit(String name,
               Object key,
               Data item,
               int index)

rollbackPoll

public void rollbackPoll(String name,
                Object key)

poll

public Object poll(String name,
          long timeout)
            throws InterruptedException

Throws:

InterruptedException

peek

public Object peek(String name)

getStorageMap

public IMap getStorageMap(String queueName)

iterate

public Iterator iterate(String name)

addKey

public boolean addKey(String name,
             Data key,
             int index)

set

public Data set(String name,
       Data key,
       int index)

removeKey

public boolean removeKey(String name,
                Data key)

generateKey

public long generateKey(String name,
               long timeout)
                 throws InterruptedException

Throws:

InterruptedException

queueSize

public int queueSize(String name)

addItemListener

public void addItemListener(String name,
                   ItemListener listener,
                   boolean includeValue)

removeItemListener

public void removeItemListener(String name,
                      ItemListener listener)