org.springframework.integration.jdbc.lock

Class JdbcLockRegistry

java.lang.Object

org.springframework.integration.jdbc.lock.JdbcLockRegistry

All Implemented Interfaces:

ExpirableLockRegistry, LockRegistry

public class JdbcLockRegistry
extends java.lang.Object
implements ExpirableLockRegistry

A LockRegistry using a shared database to co-ordinate the locks. Provides the same semantics as the DefaultLockRegistry, but the locks taken will be global, as long as the underlying database supports the "serializable" isolation level in its transactions.

Since:

4.3

Author:

Dave Syer, Artem Bilan, Vedran Pavic, Kai Zimmermann, Bartosz Rempuszewski

Constructor Summary

Constructors

Constructor and Description
JdbcLockRegistry(LockRepository client)

Method Summary

Modifier and Type	Method and Description
void	expireUnusedOlderThan(long age) Remove locks last acquired more than 'age' ago that are not currently locked.
java.util.concurrent.locks.Lock	obtain(java.lang.Object lockKey) Obtains the lock associated with the parameter object.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcLockRegistry

public JdbcLockRegistry(LockRepository client)

Method Detail

obtain

public java.util.concurrent.locks.Lock obtain(java.lang.Object lockKey)

Description copied from interface: LockRegistry

Obtains the lock associated with the parameter object.

Specified by:

obtain in interface LockRegistry

Parameters:

lockKey - The object with which the lock is associated.

Returns:

The associated lock.

expireUnusedOlderThan

public void expireUnusedOlderThan(long age)

Description copied from interface: ExpirableLockRegistry

Remove locks last acquired more than 'age' ago that are not currently locked.

Specified by:

expireUnusedOlderThan in interface ExpirableLockRegistry

Parameters:

age - the time since the lock was last obtained.