public class MapAddNearCacheInvalidationListenerMessageTask extends AbstractMapAddEntryListenerMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService
Constructor and Description |
---|
MapAddNearCacheInvalidationListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters |
decodeClientMessage(ClientMessage clientMessage) |
protected ClientMessage |
encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
encodeResponse(Object response) |
String |
getDistributedObjectName()
Used for
SecurityInterceptor |
protected EventFilter |
getEventFilter() |
Object[] |
getParameters()
Used for
SecurityInterceptor
Parameters passed to the method by a distributedObject
for map.put(key, value) parameters should be 'key' and 'value'
parameters can be in binary or object form, underlying implementation will de-serialize lazily |
protected boolean |
isLocalOnly() |
protected Object |
newMapListener() |
call, getMethodName, getRequiredPermission, getServiceName
processMessage
getClientVersion, getDistributedObjectType, getEndpoint, getMemberBuildInfo, getPartitionId, getService, handleProcessingFailure, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
public MapAddNearCacheInvalidationListenerMessageTask(ClientMessage clientMessage, Node node, Connection connection)
protected boolean isLocalOnly()
isLocalOnly
in class AbstractMapAddEntryListenerMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
protected ClientMessage encodeEvent(Data keyData, Data newValueData, Data oldValueData, Data meringValueData, int type, String uuid, int numberOfAffectedEntries)
encodeEvent
in class AbstractMapAddEntryListenerMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
public String getDistributedObjectName()
SecureRequest
SecurityInterceptor
getDistributedObjectName
in interface SecureRequest
getDistributedObjectName
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
public Object[] getParameters()
SecureRequest
SecurityInterceptor
Parameters passed to the method by a distributedObject
for map.put(key, value) parameters should be 'key' and 'value'
parameters can be in binary or object form, underlying implementation will de-serialize lazilygetParameters
in interface SecureRequest
getParameters
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
protected com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters decodeClientMessage(ClientMessage clientMessage)
decodeClientMessage
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
protected ClientMessage encodeResponse(Object response)
encodeResponse
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
protected Object newMapListener()
newMapListener
in class AbstractMapAddEntryListenerMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
protected EventFilter getEventFilter()
getEventFilter
in class AbstractMapAddEntryListenerMessageTask<com.hazelcast.client.impl.protocol.codec.MapAddNearCacheInvalidationListenerCodec.RequestParameters>
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.