Uses of Interface
org.springframework.integration.support.locks.LockRegistry
Packages that use LockRegistry
Package
Description
Provides classes related to message aggregation.
Base package for configuration.
Root package of the Spring Integration Java DSL.
Provides classes that are used to advise
MessageHandler
s with
cross-cutting concerns.Provides lock classes for JDBC module.
Provides utility classes.
Provides classes related to storing messages.
Provides classes related to leader election.
Provides classes related to locking resources.
Provides classes related to locking.
-
Uses of LockRegistry in org.springframework.integration.aggregator
Methods in org.springframework.integration.aggregator that return LockRegistryModifier and TypeMethodDescriptionprotected LockRegistry
<?> AbstractCorrelatingMessageHandler.getLockRegistry()
Methods in org.springframework.integration.aggregator with parameters of type LockRegistryModifier and TypeMethodDescriptionvoid
AbstractCorrelatingMessageHandler.setLockRegistry
(LockRegistry<?> lockRegistry) -
Uses of LockRegistry in org.springframework.integration.config
Methods in org.springframework.integration.config with parameters of type LockRegistryModifier and TypeMethodDescriptionvoid
AggregatorFactoryBean.setLockRegistry
(LockRegistry<?> lockRegistry) -
Uses of LockRegistry in org.springframework.integration.dsl
Methods in org.springframework.integration.dsl with parameters of type LockRegistryModifier and TypeMethodDescriptionCorrelationHandlerSpec.lockRegistry
(LockRegistry<?> lockRegistry) Used to obtain aLock
based on thegroupId
for concurrent operations on theMessageGroup
. -
Uses of LockRegistry in org.springframework.integration.handler.advice
Constructors in org.springframework.integration.handler.advice with parameters of type LockRegistryModifierConstructorDescriptionLockRequestHandlerAdvice
(LockRegistry<?> lockRegistry, Object lockKey) Construct an advice instance based on aLockRegistry
and fixed (shared) lock key.LockRequestHandlerAdvice
(LockRegistry<?> lockRegistry, Function<Message<?>, Object> lockKeyFunction) Construct an advice instance based on aLockRegistry
and function for the lock key against request message.LockRequestHandlerAdvice
(LockRegistry<?> lockRegistry, Expression lockKeyExpression) Construct an advice instance based on aLockRegistry
and SpEL expression for the lock key against request message. -
Uses of LockRegistry in org.springframework.integration.jdbc.lock
Classes in org.springframework.integration.jdbc.lock that implement LockRegistryModifier and TypeClassDescriptionclass
AnExpirableLockRegistry
using a shared database to co-ordinate the locks. -
Uses of LockRegistry in org.springframework.integration.redis.util
Classes in org.springframework.integration.redis.util that implement LockRegistryModifier and TypeClassDescriptionfinal class
Implementation ofExpirableLockRegistry
providing a distributed lock using Redis. -
Uses of LockRegistry in org.springframework.integration.store
Methods in org.springframework.integration.store that return LockRegistryModifier and TypeMethodDescriptionprotected LockRegistry
<?> AbstractMessageGroupStore.getLockRegistry()
Methods in org.springframework.integration.store with parameters of type LockRegistryModifier and TypeMethodDescriptionfinal void
AbstractMessageGroupStore.setLockRegistry
(LockRegistry<?> lockRegistry) Specify the type of theLockRegistry
to ensure atomic operationsConstructors in org.springframework.integration.store with parameters of type LockRegistryModifierConstructorDescriptionSimpleMessageStore
(int individualCapacity, int groupCapacity, long upperBoundTimeout, LockRegistry<?> lockRegistry) Creates a SimpleMessageStore with a maximum size limited by the given capacity, the timeout in millisecond to wait for the empty slot in the store and LockRegistry for the message group operations concurrency.SimpleMessageStore
(int individualCapacity, int groupCapacity, LockRegistry<?> lockRegistry) Creates a SimpleMessageStore with a maximum size limited by the given capacity and LockRegistry for the message group operations concurrency. -
Uses of LockRegistry in org.springframework.integration.support.leader
Constructors in org.springframework.integration.support.leader with parameters of type LockRegistryModifierConstructorDescriptionLockRegistryLeaderInitiator
(LockRegistry<?> locks) Create a new leader initiator with the provided lock registry and a default candidate (which just logs the leadership events).LockRegistryLeaderInitiator
(LockRegistry<?> locks, Candidate candidate) Create a new leader initiator. -
Uses of LockRegistry in org.springframework.integration.support.locks
Subinterfaces of LockRegistry in org.springframework.integration.support.locksModifier and TypeInterfaceDescriptioninterface
ExpirableLockRegistry<L extends Lock>
ALockRegistry
implementing this interface supports the removal of aged locks that are not currently locked.interface
RenewableLockRegistry<L extends Lock>
ALockRegistry
implementing this interface supports the renewal of the time to live of a lock.Classes in org.springframework.integration.support.locks that implement LockRegistryModifier and TypeClassDescriptionfinal class
Default implementation ofLockRegistry
which uses Masked Hashcode algorithm to obtain locks.final class
TheLockRegistry
implementation which has no effect. -
Uses of LockRegistry in org.springframework.integration.zookeeper.lock
Classes in org.springframework.integration.zookeeper.lock that implement LockRegistryModifier and TypeClassDescriptionclass
ExpirableLockRegistry
implementation using Zookeeper, or more specifically, CuratorInterProcessMutex
.