com.hazelcast.client.impl.protocol.task.replicatedmap

Class AbstractReplicatedMapAddEntryListenerMessageTask<Parameter>

java.lang.Object

com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>

com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask<Parameter>

com.hazelcast.client.impl.protocol.task.replicatedmap.AbstractReplicatedMapAddEntryListenerMessageTask<Parameter>

All Implemented Interfaces:

SecureRequest, MessageTask, EntryListener<Object,Object>, EntryAddedListener<Object,Object>, EntryEvictedListener<Object,Object>, EntryRemovedListener<Object,Object>, EntryUpdatedListener<Object,Object>, MapClearedListener, MapEvictedListener, MapListener, PartitionSpecificRunnable, Runnable, EventListener

Direct Known Subclasses:

ReplicatedMapAddEntryListenerMessageTask, ReplicatedMapAddEntryListenerToKeyMessageTask, ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask, ReplicatedMapAddEntryListenerWithPredicateMessageTask, ReplicatedMapAddNearCacheListenerMessageTask

public abstract class AbstractReplicatedMapAddEntryListenerMessageTask<Parameter>
extends AbstractCallableMessageTask<Parameter>
implements EntryListener<Object,Object>

Field Summary

Fields inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService

Constructor Summary

Constructors

Constructor and Description
AbstractReplicatedMapAddEntryListenerMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
protected Object	call()
protected abstract ClientMessage	encodeEvent(Data key, Data newValue, Data oldValue, Data mergingValue, int type, String uuid, int numberOfAffectedEntries)
void	entryAdded(EntryEvent<Object,Object> event) Invoked upon addition of an entry.
void	entryEvicted(EntryEvent<Object,Object> event) Invoked upon eviction of an entry.
void	entryRemoved(EntryEvent<Object,Object> event) Invoked upon removal of an entry.
void	entryUpdated(EntryEvent<Object,Object> event) Invoked upon update of an entry.
abstract Data	getKey()
String	getMethodName() Used for SecurityInterceptor Method name which called via a distributedObject for map.put, methodName will be 'put' For requests which do not produced via a distributedObject should return null, for example internal client.
abstract Predicate	getPredicate()
Permission	getRequiredPermission()
String	getServiceName()
protected abstract boolean	isLocalOnly()
void	mapCleared(MapEvent event) Invoked when all entries are removed by IMap.clear().
void	mapEvicted(MapEvent event) Invoked when all entries are evicted by IMap.evictAll().

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask

processMessage

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

decodeClientMessage, doRun, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getParameters, getPartitionId, getService, handleProcessingFailure, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractReplicatedMapAddEntryListenerMessageTask

public AbstractReplicatedMapAddEntryListenerMessageTask(ClientMessage clientMessage,
                                                        Node node,
                                                        Connection connection)

Method Detail

call

protected Object call()

Specified by:

call in class AbstractCallableMessageTask<Parameter>

getServiceName

public String getServiceName()

Specified by:

getServiceName in class AbstractMessageTask<Parameter>

getMethodName

public String getMethodName()

Description copied from interface: SecureRequest

Used for SecurityInterceptor Method name which called via a distributedObject for map.put, methodName will be 'put' For requests which do not produced via a distributedObject should return null, for example internal client.

Specified by:

getMethodName in interface SecureRequest

Specified by:

getMethodName in class AbstractMessageTask<Parameter>

Returns:

getRequiredPermission

public Permission getRequiredPermission()

Specified by:

getRequiredPermission in interface SecureRequest

getPredicate

public abstract Predicate getPredicate()

getKey

public abstract Data getKey()

isLocalOnly

protected abstract boolean isLocalOnly()

encodeEvent

protected abstract ClientMessage encodeEvent(Data key,
                                             Data newValue,
                                             Data oldValue,
                                             Data mergingValue,
                                             int type,
                                             String uuid,
                                             int numberOfAffectedEntries)

entryAdded

public void entryAdded(EntryEvent<Object,Object> event)

Description copied from interface: EntryAddedListener

Invoked upon addition of an entry.

Specified by:

entryAdded in interface EntryAddedListener<Object,Object>

Parameters:

event - the event invoked when an entry is added

entryRemoved

public void entryRemoved(EntryEvent<Object,Object> event)

Description copied from interface: EntryRemovedListener

Invoked upon removal of an entry.

Specified by:

entryRemoved in interface EntryRemovedListener<Object,Object>

Parameters:

event - the event invoked when an entry is removed

entryUpdated

public void entryUpdated(EntryEvent<Object,Object> event)

Description copied from interface: EntryUpdatedListener

Invoked upon update of an entry.

Specified by:

entryUpdated in interface EntryUpdatedListener<Object,Object>

Parameters:

event - the event invoked when an entry is updated

entryEvicted

public void entryEvicted(EntryEvent<Object,Object> event)

Description copied from interface: EntryEvictedListener

Invoked upon eviction of an entry.

Specified by:

entryEvicted in interface EntryEvictedListener<Object,Object>

Parameters:

event - the event invoked when an entry is evicted

mapEvicted

public void mapEvicted(MapEvent event)

Description copied from interface: MapEvictedListener

Invoked when all entries are evicted by IMap.evictAll().

Specified by:

mapEvicted in interface MapEvictedListener

Parameters:

event - the map event invoked when all entries are evicted by IMap.evictAll()

mapCleared

public void mapCleared(MapEvent event)

Description copied from interface: MapClearedListener

Invoked when all entries are removed by IMap.clear(). When a listener is registered as local-only then it will be invoked if and only if the clear() method is called on the same instance where the listener was registered to.

Specified by:

mapCleared in interface MapClearedListener

Parameters:

event - the map event invoked when all entries are removed by IMap.clear()