public abstract class Operation extends Object implements DataSerializable, com.hazelcast.spi.impl.RemotePropagatable<Operation>
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() |
String |
getExecutorName() |
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() |
long |
getWaitTimeout() |
boolean |
isUrgent() |
void |
logError(Throwable e) |
ExceptionAction |
onException(Throwable throwable) |
void |
readData(com.hazelcast.nio.ObjectDataInput in)
Reads fields from the input stream
|
protected abstract void |
readInternal(com.hazelcast.nio.ObjectDataInput in) |
abstract boolean |
returnsResponse() |
abstract void |
run() |
Operation |
setCallerUuid(String callerUuid) |
void |
setExecutorName(String executorName) |
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) |
void |
setWaitTimeout(long timeout) |
boolean |
validatesTarget() |
void |
writeData(com.hazelcast.nio.ObjectDataOutput out)
Writes object fields to output stream
|
protected abstract void |
writeInternal(com.hazelcast.nio.ObjectDataOutput out) |
public boolean isUrgent()
isUrgent
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
public abstract boolean returnsResponse()
returnsResponse
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
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 String getExecutorName()
public void setExecutorName(String executorName)
public final long getCallId()
getCallId
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
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()
getCallerAddress
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
public final com.hazelcast.nio.Connection getConnection()
getConnection
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
public final Operation setResponseHandler(ResponseHandler responseHandler)
setResponseHandler
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
public final ResponseHandler getResponseHandler()
getResponseHandler
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
public final long getStartTime()
public final long getInvocationTime()
public final long getCallTimeout()
public final long getWaitTimeout()
public final void setWaitTimeout(long timeout)
public ExceptionAction onException(Throwable throwable)
public String getCallerUuid()
protected final com.hazelcast.logging.ILogger getLogger()
public void logError(Throwable e)
logError
in interface com.hazelcast.spi.impl.RemotePropagatable<Operation>
public final void writeData(com.hazelcast.nio.ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
out
- outputIOException
public final void readData(com.hazelcast.nio.ObjectDataInput in) throws IOException
DataSerializable
readData
in interface DataSerializable
in
- inputIOException
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 © 2014 Hazelcast, Inc.. All Rights Reserved.