public abstract class BaseManager.ResponseQueueCall extends Object
Modifier and Type | Field and Description |
---|---|
protected long |
callId |
protected CallState |
callState |
protected int |
enqueueCount |
protected Constants.RedoType |
redoType |
protected Request |
request |
Constructor and Description |
---|
BaseManager.ResponseQueueCall() |
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) |
protected boolean |
canTimeout() |
void |
clearRequest() |
void |
doOp() |
long |
getCallId() |
CallState |
getCallState() |
int |
getEnqueueCount() |
protected Object |
getRedoAwareResult() |
Object |
getResult() |
Object |
getResult(long time,
TimeUnit unit) |
boolean |
getResultAsBoolean() |
boolean |
getResultAsBoolean(int timeoutSeconds) |
Object |
getResultAsIs() |
Object |
getResultAsObject() |
Object |
getResultAsObject(boolean forceDataResult) |
protected Address |
getTarget() |
protected void |
handleInterruption() |
protected void |
handleNoneRedoResponse(Packet packet) |
protected void |
initCall() |
protected boolean |
isInterruptible() |
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 |
redo(Constants.RedoType redoType) |
void |
redo(int redoTypeCode) |
void |
reset() |
void |
setCallId(long callId) |
void |
setLocal(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long ttl) |
protected void |
setRedoResult(Constants.RedoType redoType) |
protected void |
setResult(Object obj) |
String |
toString() |
Object |
waitAndGetResult() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
handleResponse
process
protected Constants.RedoType redoType
protected final Request request
protected long callId
protected int enqueueCount
protected CallState callState
public void doOp()
public void beforeRedo()
public Object getResult(long time, TimeUnit unit) throws InterruptedException
InterruptedException
public boolean getResultAsBoolean(int timeoutSeconds)
protected void onStillWaiting()
public Object waitAndGetResult()
public Object getResult()
protected final Object getRedoAwareResult()
protected Address getTarget()
public void redo(int redoTypeCode)
protected void redo(Constants.RedoType redoType)
public void reset()
protected void handleNoneRedoResponse(Packet packet)
protected void setRedoResult(Constants.RedoType redoType)
protected void setResult(Object obj)
protected void handleInterruption()
protected boolean isInterruptible()
protected boolean canTimeout()
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 String toString()
public CallState getCallState()
getCallState
in interface CallStateAware
protected void initCall()
public void onDisconnect(Address dead)
onDisconnect
in interface Call
public int getEnqueueCount()
getEnqueueCount
in interface Call
Copyright © 2013 Hazelcast, Inc.. All rights reserved.