public abstract class BaseManager.TargetAwareOp extends BaseManager.ResponseQueueCall
Modifier and Type | Field and Description |
---|---|
protected long |
callId |
protected CallState |
callState |
protected int |
enqueueCount |
protected Request |
request |
protected Address |
target |
protected Connection |
targetConnection |
redoType
Constructor and Description |
---|
BaseManager.TargetAwareOp() |
Modifier and Type | Method and Description |
---|---|
protected void |
afterGettingResult(Request request) |
void |
beforeRedo() |
boolean |
booleanCall(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long recordId) |
void |
clearRequest() |
void |
doLocalOp() |
protected Packet |
doObtainPacket() |
protected void |
doReleasePacket(Packet packet) |
long |
getCallId() |
CallState |
getCallState() |
int |
getEnqueueCount() |
boolean |
getResultAsBoolean() |
Object |
getResultAsIs() |
Object |
getResultAsObject() |
Object |
getResultAsObject(boolean forceDataResult) |
Address |
getTarget() |
void |
handleResponse(Packet packet) |
protected void |
initCall() |
protected void |
invoke() |
protected void |
memberDoesNotExist() |
protected boolean |
memberOnly() |
Object |
objectCall() |
Object |
objectCall(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long ttl) |
void |
onDisconnect(Address dead) |
void |
onEnqueue() |
protected void |
onStillWaiting() |
protected void |
packetNotSent() |
void |
process() |
void |
reset() |
void |
setCallId(long callId) |
void |
setLocal(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long ttl) |
abstract void |
setTarget() |
protected void |
throwTxTimeoutException(Object key) |
String |
toString() |
canTimeout, doOp, getRedoAwareResult, getResult, getResult, getResultAsBoolean, handleInterruption, handleNoneRedoResponse, isInterruptible, redo, redo, setRedoResult, setResult, waitAndGetResult
protected Address target
protected Connection targetConnection
protected final Request request
protected long callId
protected int enqueueCount
protected CallState callState
public void handleResponse(Packet packet)
protected void doReleasePacket(Packet packet)
protected Packet doObtainPacket()
protected void onStillWaiting()
onStillWaiting
in class BaseManager.ResponseQueueCall
public void onDisconnect(Address dead)
onDisconnect
in interface Call
public void reset()
reset
in class BaseManager.ResponseQueueCall
public void beforeRedo()
beforeRedo
in class BaseManager.ResponseQueueCall
public void process()
protected boolean memberOnly()
protected void memberDoesNotExist()
protected void invoke()
protected void packetNotSent()
public void doLocalOp()
public abstract void setTarget()
public Address getTarget()
getTarget
in class BaseManager.ResponseQueueCall
protected void throwTxTimeoutException(Object key)
public String toString()
public boolean booleanCall(ClusterOperation operation, String name, Object key, Object value, long timeout, long recordId)
public void clearRequest()
public boolean getResultAsBoolean()
public Object getResultAsObject()
public Object getResultAsObject(boolean forceDataResult)
public Object getResultAsIs()
protected void afterGettingResult(Request request)
public Object objectCall()
public Object objectCall(ClusterOperation operation, String name, Object key, Object value, long timeout, long ttl)
public void setLocal(ClusterOperation operation, String name, Object key, Object value, long timeout, long ttl)
public CallState getCallState()
getCallState
in interface CallStateAware
protected void initCall()
public int getEnqueueCount()
getEnqueueCount
in interface Call
Copyright © 2013 Hazelcast, Inc.. All rights reserved.