com.hazelcast.client.impl.protocol.task

Class AbstractRemoveListenerMessageTask<P>

java.lang.Object

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

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

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

Type Parameters:

P - listener registration request parameters type

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

CacheRemoveEntryListenerMessageTask, CacheRemoveInvalidationListenerMessageTask, CacheRemovePartitionLostListenerMessageTask, ListRemoveListenerMessageTask, MapRemoveEntryListenerMessageTask, MapRemovePartitionLostListenerMessageTask, MultiMapRemoveEntryListenerMessageTask, QueueRemoveListenerMessageTask, RemoveDistributedObjectListenerMessageTask, RemovePartitionLostListenerMessageTask, ReplicatedMapRemoveEntryListenerMessageTask, SetRemoveListenerMessageTask, TopicRemoveMessageListenerMessageTask

public abstract class AbstractRemoveListenerMessageTask<P>
extends AbstractCallableMessageTask<P>

Base class for remove listener message tasks that removes a client listener registration from a node

Field Summary

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

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractRemoveListenerMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
Object	call()
protected abstract boolean	deRegisterListener()
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 abstract String	getRegistrationId()

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

processMessage

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

decodeClientMessage, encodeResponse, getClientVersion, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMemberBuildInfo, getMethodName, getPartitionId, getService, getServiceName, handleProcessingFailure, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.client.impl.client.SecureRequest

getRequiredPermission

Constructor Detail

AbstractRemoveListenerMessageTask

protected AbstractRemoveListenerMessageTask(ClientMessage clientMessage,
                                            Node node,
                                            Connection connection)

Method Detail

call

public final Object call()

Specified by:

call in class AbstractCallableMessageTask<P>

deRegisterListener

protected abstract boolean deRegisterListener()

getRegistrationId

protected abstract String getRegistrationId()

getParameters

public Object[] getParameters()

Description copied from interface: SecureRequest

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

Specified by:

getParameters in interface SecureRequest

Specified by:

getParameters in class AbstractMessageTask<P>

Returns: