com.espertech.esper.client.deploy

Class DeploymentLockStrategyWTimeout

java.lang.Object

com.espertech.esper.client.deploy.DeploymentLockStrategyWTimeout

All Implemented Interfaces:

DeploymentLockStrategy

public class DeploymentLockStrategyWTimeout
extends Object
implements DeploymentLockStrategy

Obtains the write lock of the engine-wide event processing read-write lock by trying the lock waiting for the timeout and throwing an exception if the lock was not taken.

Constructor Summary

Constructors

Constructor and Description
DeploymentLockStrategyWTimeout(long timeout, TimeUnit unit) Ctor.

Method Summary

Modifier and Type	Method and Description
void	acquire(ManagedReadWriteLock engineWideLock) Acquire should acquire the write lock of the provided read-write lock and may retry and backoff or fail.
void	release(ManagedReadWriteLock engineWideLock) Release should release the write lock of the provided read-write lock and should never fail.

Methods inherited from class java.lang.Object

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

Constructor Detail

DeploymentLockStrategyWTimeout

public DeploymentLockStrategyWTimeout(long timeout,
                                      TimeUnit unit)

Ctor.

Parameters:

timeout - timeout value in the unit given

unit - unit

Method Detail

acquire

public void acquire(ManagedReadWriteLock engineWideLock)
             throws DeploymentLockException,
                    InterruptedException

Description copied from interface: DeploymentLockStrategy

Acquire should acquire the write lock of the provided read-write lock and may retry and backoff or fail.

Specified by:

acquire in interface DeploymentLockStrategy

Parameters:

engineWideLock - the engine-wide event processing read-write lock

Throws:

DeploymentLockException - to indicate lock attempt failed

InterruptedException - when lock-taking is interrupted

release

public void release(ManagedReadWriteLock engineWideLock)

Description copied from interface: DeploymentLockStrategy

Release should release the write lock of the provided read-write lock and should never fail.

Specified by:

release in interface DeploymentLockStrategy

Parameters:

engineWideLock - the engine-wide event processing read-write lock