public class AddDistributedObjectListenerMessageTask extends AbstractCallableMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters> implements DistributedObjectListener
clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService
Constructor and Description |
---|
AddDistributedObjectListenerMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected Object |
call() |
protected com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters |
decodeClientMessage(ClientMessage clientMessage) |
void |
distributedObjectCreated(DistributedObjectEvent event)
Invoked when a DistributedObject is created.
|
void |
distributedObjectDestroyed(DistributedObjectEvent event)
Invoked when a DistributedObject is destroyed.
|
protected ClientMessage |
encodeResponse(Object response) |
String |
getDistributedObjectName()
Used for
SecurityInterceptor |
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. |
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 |
Permission |
getRequiredPermission() |
String |
getServiceName() |
processMessage
getClientVersion, getDistributedObjectType, getEndpoint, getMemberBuildInfo, getPartitionId, getService, handleProcessingFailure, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
public AddDistributedObjectListenerMessageTask(ClientMessage clientMessage, Node node, Connection connection)
protected Object call() throws Exception
call
in class AbstractCallableMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters>
Exception
protected com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters decodeClientMessage(ClientMessage clientMessage)
decodeClientMessage
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters>
protected ClientMessage encodeResponse(Object response)
encodeResponse
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters>
public String getServiceName()
getServiceName
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters>
public Permission getRequiredPermission()
getRequiredPermission
in interface SecureRequest
public String getDistributedObjectName()
SecureRequest
SecurityInterceptor
getDistributedObjectName
in interface SecureRequest
getDistributedObjectName
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.RequestParameters>
public String getMethodName()
SecureRequest
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.getMethodName
in interface SecureRequest
getMethodName
in class AbstractMessageTask<com.hazelcast.client.impl.protocol.codec.ClientAddDistributedObjectListenerCodec.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.ClientAddDistributedObjectListenerCodec.RequestParameters>
public void distributedObjectCreated(DistributedObjectEvent event)
DistributedObjectListener
distributedObjectCreated
in interface DistributedObjectListener
event
- the event for the created DistributedObjectpublic void distributedObjectDestroyed(DistributedObjectEvent event)
DistributedObjectListener
distributedObjectDestroyed
in interface DistributedObjectListener
event
- the event for the destroyed DistributedObjectCopyright © 2017 Hazelcast, Inc.. All Rights Reserved.