Uses of Interface
org.springframework.integration.support.locks.LockRegistry
Package
Description
Provides classes related to message aggregation.
Base package for configuration.
Root package of the Spring Integration Java DSL.
Provides the distributed Locks support classes.
Provides utility classes.
Provides classes releated to storing messages.
Provides classes related to locking resources.
Provides classes related to locking.
-
Uses of LockRegistry in org.springframework.integration.aggregator
Modifier and TypeMethodDescriptionprotected LockRegistry
AbstractCorrelatingMessageHandler.getLockRegistry()
Modifier and TypeMethodDescriptionvoid
AbstractCorrelatingMessageHandler.setLockRegistry
(LockRegistry lockRegistry) -
Uses of LockRegistry in org.springframework.integration.config
Modifier and TypeMethodDescriptionvoid
AggregatorFactoryBean.setLockRegistry
(LockRegistry lockRegistry) -
Uses of LockRegistry in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionCorrelationHandlerSpec.lockRegistry
(LockRegistry lockRegistry) Used to obtain aLock
based on thegroupId
for concurrent operations on theMessageGroup
. -
Uses of LockRegistry in org.springframework.integration.hazelcast.lock
Modifier and TypeClassDescriptionclass
ALockRegistry
implementation Hazelcast distributed locks. -
Uses of LockRegistry in org.springframework.integration.jdbc.lock
Modifier and TypeClassDescriptionclass
AnExpirableLockRegistry
using a shared database to co-ordinate the locks. -
Uses of LockRegistry in org.springframework.integration.redis.util
Modifier and TypeClassDescriptionfinal class
Implementation ofExpirableLockRegistry
providing a distributed lock using Redis. -
Uses of LockRegistry in org.springframework.integration.store
Modifier and TypeMethodDescriptionvoid
SimpleMessageStore.setLockRegistry
(LockRegistry lockRegistry) ModifierConstructorDescriptionSimpleMessageStore
(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
ModifierConstructorDescriptionCreate 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
Modifier and TypeInterfaceDescriptioninterface
ALockRegistry
implementing this interface supports the removal of aged locks that are not currently locked.interface
ALockRegistry
implementing this interface supports the renewal of the time to live of a lock.Modifier 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
Modifier and TypeClassDescriptionclass
ExpirableLockRegistry
implementation using Zookeeper, or more specifically, CuratorInterProcessMutex
.