public class ListenerManager extends BaseManager
Modifier and Type | Class and Description |
---|---|
class |
ListenerManager.AddRemoveListener |
static class |
ListenerManager.ListenerItem |
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 |
---|---|
void |
addListener(String name,
Object listener,
Object key,
boolean includeValue,
Instance.InstanceType instanceType) |
void |
addLocalListener(String name,
Object listener,
Instance.InstanceType instanceType) |
List<ListenerManager.ListenerItem> |
getOrCreateListenerList(String name) |
void |
removeListener(String name,
Object listener,
Object key) |
void |
syncForAdd() |
void |
syncForAdd(Address newAddress) |
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 syncForDead(Address deadAddress)
public void syncForAdd()
public void syncForAdd(Address newAddress)
public void addLocalListener(String name, Object listener, Instance.InstanceType instanceType)
public List<ListenerManager.ListenerItem> getOrCreateListenerList(String name)
public void addListener(String name, Object listener, Object key, boolean includeValue, Instance.InstanceType instanceType)
Copyright © 2013 Hazelcast, Inc.. All rights reserved.