com.hazelcast.client.proxy

Class ClientConditionProxy

java.lang.Object

com.hazelcast.client.spi.ClientProxy

com.hazelcast.client.proxy.ClientConditionProxy

All Implemented Interfaces:

DistributedObject, ICondition, Condition

public class ClientConditionProxy
extends ClientProxy
implements ICondition

Proxy implementation of ICondition.

Field Summary

Fields inherited from class com.hazelcast.client.spi.ClientProxy

name

Constructor Summary

Constructors

Constructor and Description
ClientConditionProxy(ClientLockProxy clientLockProxy, String name, ClientContext context)

Method Summary

Modifier and Type	Method and Description
void	await()
boolean	await(long time, TimeUnit unit)
long	awaitNanos(long nanosTimeout)
void	awaitUninterruptibly()
boolean	awaitUntil(Date deadline)
protected ClientMessage	invokeOnPartition(ClientMessage req)
protected <T> T	invokeOnPartition(ClientMessage clientMessage, long invocationTimeoutSeconds)
protected <T> ClientDelegatingFuture<T>	invokeOnPartitionAsync(ClientMessage clientMessage, ClientMessageDecoder clientMessageDecoder)
protected <T> T	invokeOnPartitionInterruptibly(ClientMessage clientMessage)
protected <T> T	invokeOnPartitionInterruptibly(ClientMessage clientMessage, long invocationTimeoutSeconds)
protected void	onInitialize() Called when proxy is created.
void	signal()
void	signalAll()

Methods inherited from class com.hazelcast.client.spi.ClientProxy

deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getConnectedServerVersion, getContext, getDistributedObjectName, getId, getName, getPartitionKey, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onDestroy, onShutdown, postDestroy, preDestroy, registerListener, setContext, toData, toObject

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientConditionProxy

public ClientConditionProxy(ClientLockProxy clientLockProxy,
                            String name,
                            ClientContext context)

Method Detail

await

public void await()
           throws InterruptedException

Specified by:

await in interface Condition

Throws:

InterruptedException

awaitUninterruptibly

public void awaitUninterruptibly()

Specified by:

awaitUninterruptibly in interface Condition

awaitNanos

public long awaitNanos(long nanosTimeout)
                throws InterruptedException

Specified by:

awaitNanos in interface Condition

Throws:

InterruptedException

await

public boolean await(long time,
                     TimeUnit unit)
              throws InterruptedException

Specified by:

await in interface Condition

Throws:

InterruptedException

awaitUntil

public boolean awaitUntil(Date deadline)
                   throws InterruptedException

Specified by:

awaitUntil in interface Condition

Throws:

InterruptedException

signal

public void signal()

Specified by:

signal in interface Condition

signalAll

public void signalAll()

Specified by:

signalAll in interface Condition

onInitialize

protected void onInitialize()

Description copied from class: ClientProxy

Called when proxy is created. Overriding implementations can add initialization specific logic into this method like registering a listener, creating a cleanup task etc.

invokeOnPartition

protected ClientMessage invokeOnPartition(ClientMessage req)

invokeOnPartitionInterruptibly

protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage)
                                        throws InterruptedException

Throws:

InterruptedException

invokeOnPartitionAsync

protected <T> ClientDelegatingFuture<T> invokeOnPartitionAsync(ClientMessage clientMessage,
                                                               ClientMessageDecoder clientMessageDecoder)

invokeOnPartition

protected <T> T invokeOnPartition(ClientMessage clientMessage,
                                  long invocationTimeoutSeconds)

invokeOnPartitionInterruptibly

protected <T> T invokeOnPartitionInterruptibly(ClientMessage clientMessage,
                                               long invocationTimeoutSeconds)
                                        throws InterruptedException

Throws:

InterruptedException