public abstract class Operation extends Object implements DataSerializable
Runnable
. So it contains logic that is going to be executed; this logic
will be placed in the run()
method.Constructor and Description |
---|
Operation() |
Modifier and Type | Method and Description |
---|---|
abstract void |
afterRun() |
abstract void |
beforeRun() |
com.hazelcast.nio.Address |
getCallerAddress() |
String |
getCallerUuid() |
long |
getCallId() |
long |
getCallTimeout() |
com.hazelcast.nio.Connection |
getConnection() |
long |
getInvocationTime() |
protected com.hazelcast.logging.ILogger |
getLogger() |
NodeEngine |
getNodeEngine() |
int |
getPartitionId() |
int |
getReplicaIndex() |
abstract Object |
getResponse() |
ResponseHandler |
getResponseHandler() |
<T> T |
getService() |
String |
getServiceName() |
long |
getStartTime() |
boolean |
isAsync() |
void |
logError(Throwable e) |
ExceptionAction |
onException(Throwable throwable) |
void |
readData(com.hazelcast.nio.ObjectDataInput in) |
protected abstract void |
readInternal(com.hazelcast.nio.ObjectDataInput in) |
abstract boolean |
returnsResponse() |
abstract void |
run() |
Operation |
setCallerUuid(String callerUuid) |
Operation |
setNodeEngine(NodeEngine nodeEngine) |
Operation |
setPartitionId(int partitionId) |
Operation |
setReplicaIndex(int replicaIndex) |
Operation |
setResponseHandler(ResponseHandler responseHandler) |
Operation |
setService(Object service) |
Operation |
setServiceName(String serviceName) |
Operation |
setValidateTarget(boolean validateTarget) |
boolean |
validatesTarget() |
void |
writeData(com.hazelcast.nio.ObjectDataOutput out) |
protected abstract void |
writeInternal(com.hazelcast.nio.ObjectDataOutput out) |
public abstract boolean returnsResponse()
public abstract Object getResponse()
public String getServiceName()
public final int getPartitionId()
public final Operation setPartitionId(int partitionId)
public final int getReplicaIndex()
public final Operation setReplicaIndex(int replicaIndex)
public final long getCallId()
public boolean validatesTarget()
public final Operation setValidateTarget(boolean validateTarget)
public final NodeEngine getNodeEngine()
public final Operation setNodeEngine(NodeEngine nodeEngine)
public final <T> T getService()
public final com.hazelcast.nio.Address getCallerAddress()
public final com.hazelcast.nio.Connection getConnection()
public final Operation setResponseHandler(ResponseHandler responseHandler)
public final ResponseHandler getResponseHandler()
public final long getStartTime()
public final long getInvocationTime()
public final long getCallTimeout()
public ExceptionAction onException(Throwable throwable)
public String getCallerUuid()
public boolean isAsync()
protected final com.hazelcast.logging.ILogger getLogger()
public void logError(Throwable e)
public final void writeData(com.hazelcast.nio.ObjectDataOutput out) throws IOException
writeData
in interface DataSerializable
IOException
public final void readData(com.hazelcast.nio.ObjectDataInput in) throws IOException
readData
in interface DataSerializable
IOException
protected abstract void writeInternal(com.hazelcast.nio.ObjectDataOutput out) throws IOException
IOException
protected abstract void readInternal(com.hazelcast.nio.ObjectDataInput in) throws IOException
IOException
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.