com.hazelcast.cluster

Class ClusterManager.AsyncRemotelyBooleanOp

java.lang.Object

com.hazelcast.impl.BaseManager.ResponseQueueCall

com.hazelcast.impl.BaseManager.TargetAwareOp

com.hazelcast.cluster.ClusterManager.AsyncRemotelyBooleanOp

All Implemented Interfaces:

Call, CallStateAware, Processable

Direct Known Subclasses:

ClusterManager.NoneMemberAsyncRemotelyBooleanOp

Enclosing class:

ClusterManager

public class ClusterManager.AsyncRemotelyBooleanOp
extends BaseManager.TargetAwareOp

Field Summary

Fields

Modifier and Type	Field and Description
protected long	callId
protected CallState	callState
protected int	enqueueCount
protected Request	request

Fields inherited from class com.hazelcast.impl.BaseManager.TargetAwareOp

target, targetConnection

Fields inherited from class com.hazelcast.impl.BaseManager.ResponseQueueCall

redoType

Constructor Summary

Constructors

Constructor and Description
ClusterManager.AsyncRemotelyBooleanOp(AbstractRemotelyCallable<Boolean> arp, Address target, boolean canTimeout)

Method Summary

Methods

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()

Methods inherited from class com.hazelcast.impl.BaseManager.TargetAwareOp

beforeRedo, doObtainPacket, doReleasePacket, handleResponse, invoke, memberOnly, onStillWaiting, process, reset, throwTxTimeoutException, toString

Methods inherited from class com.hazelcast.impl.BaseManager.ResponseQueueCall

doOp, getRedoAwareResult, getResult, getResult, getResultAsBoolean, handleInterruption, handleNoneRedoResponse, isInterruptible, redo, setRedoResult, setResult, waitAndGetResult

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

request

protected final Request request

callId

protected long callId

enqueueCount

protected int enqueueCount

callState

protected CallState callState

Constructor Detail

ClusterManager.AsyncRemotelyBooleanOp

public ClusterManager.AsyncRemotelyBooleanOp(AbstractRemotelyCallable<Boolean> arp,
                                     Address target,
                                     boolean canTimeout)

Method Detail

execute

public void execute()

getTarget

public Address getTarget()

Overrides:

getTarget in class BaseManager.TargetAwareOp

onDisconnect

public void onDisconnect(Address dead)

Specified by:

onDisconnect in interface Call

Overrides:

onDisconnect in class BaseManager.TargetAwareOp

doLocalOp

public void doLocalOp()

Overrides:

doLocalOp in class BaseManager.TargetAwareOp

setTarget

public void setTarget()

Specified by:

setTarget in class BaseManager.TargetAwareOp

redo

public void redo(int redoTypeCode)

Overrides:

redo in class BaseManager.ResponseQueueCall

memberDoesNotExist

protected void memberDoesNotExist()

Overrides:

memberDoesNotExist in class BaseManager.TargetAwareOp

packetNotSent

protected void packetNotSent()

Overrides:

packetNotSent in class BaseManager.TargetAwareOp

canTimeout

protected final boolean canTimeout()

Overrides:

canTimeout in class BaseManager.ResponseQueueCall

booleanCall

public boolean booleanCall(ClusterOperation operation,
                  String name,
                  Object key,
                  Object value,
                  long timeout,
                  long recordId)

clearRequest

public void clearRequest()

getResultAsBoolean

public boolean getResultAsBoolean()

getResultAsObject

public Object getResultAsObject()

getResultAsObject

public Object getResultAsObject(boolean forceDataResult)

getResultAsIs

public Object getResultAsIs()

afterGettingResult

protected void afterGettingResult(Request request)

objectCall

public Object objectCall()

objectCall

public Object objectCall(ClusterOperation operation,
                String name,
                Object key,
                Object value,
                long timeout,
                long ttl)

setLocal

public void setLocal(ClusterOperation operation,
            String name,
            Object key,
            Object value,
            long timeout,
            long ttl)

getCallState

public CallState getCallState()

Specified by:

getCallState in interface CallStateAware

initCall

protected void initCall()

getCallId

public long getCallId()

Specified by:

getCallId in interface Call

onEnqueue

public void onEnqueue()

Specified by:

onEnqueue in interface Call

setCallId

public void setCallId(long callId)

Specified by:

setCallId in interface Call

getEnqueueCount

public int getEnqueueCount()

Specified by:

getEnqueueCount in interface Call