public class ClusterManager.AsyncRemotelyBooleanOp extends BaseManager.TargetAwareOp
Modifier and Type | Field and Description |
---|---|
protected long |
callId |
protected CallState |
callState |
protected int |
enqueueCount |
protected Request |
request |
target, targetConnection
redoType
Constructor and Description |
---|
ClusterManager.AsyncRemotelyBooleanOp(AbstractRemotelyCallable<Boolean> arp,
Address target,
boolean canTimeout) |
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) |
protected boolean |
canTimeout() |
void |
clearRequest() |
void |
doLocalOp() |
void |
execute() |
long |
getCallId() |
CallState |
getCallState() |
int |
getEnqueueCount() |
boolean |
getResultAsBoolean() |
Object |
getResultAsIs() |
Object |
getResultAsObject() |
Object |
getResultAsObject(boolean forceDataResult) |
Address |
getTarget() |
protected void |
initCall() |
protected void |
memberDoesNotExist() |
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 |
redo(int redoTypeCode) |
void |
setCallId(long callId) |
void |
setLocal(ClusterOperation operation,
String name,
Object key,
Object value,
long timeout,
long ttl) |
void |
setTarget() |
beforeRedo, doObtainPacket, doReleasePacket, handleResponse, invoke, memberOnly, onStillWaiting, process, reset, throwTxTimeoutException, toString
doOp, getRedoAwareResult, getResult, getResult, getResultAsBoolean, handleInterruption, handleNoneRedoResponse, isInterruptible, redo, setRedoResult, setResult, waitAndGetResult
protected final Request request
protected long callId
protected int enqueueCount
protected CallState callState
public ClusterManager.AsyncRemotelyBooleanOp(AbstractRemotelyCallable<Boolean> arp, Address target, boolean canTimeout)
public void execute()
public Address getTarget()
getTarget
in class BaseManager.TargetAwareOp
public void onDisconnect(Address dead)
onDisconnect
in interface Call
onDisconnect
in class BaseManager.TargetAwareOp
public void doLocalOp()
doLocalOp
in class BaseManager.TargetAwareOp
public void setTarget()
setTarget
in class BaseManager.TargetAwareOp
public void redo(int redoTypeCode)
redo
in class BaseManager.ResponseQueueCall
protected void memberDoesNotExist()
memberDoesNotExist
in class BaseManager.TargetAwareOp
protected void packetNotSent()
packetNotSent
in class BaseManager.TargetAwareOp
protected final boolean canTimeout()
canTimeout
in class BaseManager.ResponseQueueCall
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.