com.hazelcast.impl

Class BaseManager.ConnectionAwareOp

java.lang.Object

com.hazelcast.impl.BaseManager.ResponseQueueCall

com.hazelcast.impl.BaseManager.ConnectionAwareOp

All Implemented Interfaces:

Call, CallStateAware, Processable

Enclosing class:

BaseManager

public abstract class BaseManager.ConnectionAwareOp
extends BaseManager.ResponseQueueCall

Field Summary

Fields

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

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

redoType

Constructor Summary

Constructors

Constructor and Description
BaseManager.ConnectionAwareOp(Connection targetConnection)

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

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

beforeRedo, canTimeout, doOp, getRedoAwareResult, getResult, getResult, getResultAsBoolean, getTarget, handleInterruption, handleNoneRedoResponse, isInterruptible, onStillWaiting, redo, redo, setRedoResult, setResult, waitAndGetResult

Methods inherited from class java.lang.Object

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

Field Detail

targetConnection

protected final Connection targetConnection

request

protected final Request request

callId

protected long callId

enqueueCount

protected int enqueueCount

callState

protected CallState callState

Constructor Detail

BaseManager.ConnectionAwareOp

public BaseManager.ConnectionAwareOp(Connection targetConnection)

Method Detail

handleResponse

public void handleResponse(Packet packet)

onDisconnect

public void onDisconnect(Address dead)

Specified by:

onDisconnect in interface Call

reset

public void reset()

Overrides:

reset in class BaseManager.ResponseQueueCall

process

public void process()

invoke

protected void invoke()

packetNotSent

protected void packetNotSent()

toString

public String toString()

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