public abstract class BaseManager.ConnectionAwareOp extends BaseManager.ResponseQueueCall
Modifier and Type | Field and Description |
---|---|
protected long |
callId |
protected CallState |
callState |
protected int |
enqueueCount |
protected Request |
request |
protected Connection |
targetConnection |
redoType
Constructor and Description |
---|
BaseManager.ConnectionAwareOp(Connection targetConnection) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterGettingResult(Request request) |
boolean |
booleanCall(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long recordId) |
void |
clearRequest() |
long |
getCallId() |
CallState |
getCallState() |
int |
getEnqueueCount() |
boolean |
getResultAsBoolean() |
Object |
getResultAsIs() |
Object |
getResultAsObject() |
Object |
getResultAsObject(boolean forceDataResult) |
void |
handleResponse(Packet packet) |
protected void |
initCall() |
protected void |
invoke() |
Object |
objectCall() |
Object |
objectCall(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long ttl) |
void |
onDisconnect(Address dead) |
void |
onEnqueue() |
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) |
String |
toString() |
beforeRedo, canTimeout, doOp, getRedoAwareResult, getResult, getResult, getResultAsBoolean, getTarget, handleInterruption, handleNoneRedoResponse, isInterruptible, onStillWaiting, redo, redo, setRedoResult, setResult, waitAndGetResult
protected final Connection targetConnection
protected final Request request
protected long callId
protected int enqueueCount
protected CallState callState
public BaseManager.ConnectionAwareOp(Connection targetConnection)
public void handleResponse(Packet packet)
public void onDisconnect(Address dead)
onDisconnect
in interface Call
public void reset()
reset
in class BaseManager.ResponseQueueCall
public void process()
protected void invoke()
protected void packetNotSent()
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.