Package com.dehnes.kotlinredis.lock
Class WaitersManager
-
- All Implemented Interfaces:
public final class WaitersManager
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public final classWaitersManager.WaitersMessage
-
Constructor Summary
Constructors Constructor Description WaitersManager(RedisPubSubService redisPubSubService, LockServiceJsonHandler lockServiceJsonHandler, String channel, Integer messageBufferLimit)
-
Method Summary
Modifier and Type Method Description final UnitpublishWaiter(ThreadWaitingInfo waitingInfo, Long now, Duration connectionPoolTimeout)final UnitpublishNotWaiting(ThreadId threadId, Duration connectionPoolTimeout)final Map<ThreadId, ThreadWaitingInfo>getAll(Long now)-
-
Constructor Detail
-
WaitersManager
WaitersManager(RedisPubSubService redisPubSubService, LockServiceJsonHandler lockServiceJsonHandler, String channel, Integer messageBufferLimit)
-
-
Method Detail
-
publishWaiter
final Unit publishWaiter(ThreadWaitingInfo waitingInfo, Long now, Duration connectionPoolTimeout)
- Parameters:
connectionPoolTimeout- max time to wait for a pool connection - the publish is skipped (logged) otherwise
-
publishNotWaiting
final Unit publishNotWaiting(ThreadId threadId, Duration connectionPoolTimeout)
- Parameters:
connectionPoolTimeout- max time to wait for a pool connection - the publish is skipped (logged) otherwise
-
getAll
final Map<ThreadId, ThreadWaitingInfo> getAll(Long now)
-
-
-
-