Package at.aimon.session.web.spi.inmemory

Class InMemoryConversationLock

java.lang.Object

at.aimon.session.web.spi.inmemory.InMemoryConversationLock

All Implemented Interfaces:

ConversationLock

public final class InMemoryConversationLock
extends Object
implements ConversationLock

Single-process ConversationLock backed by a ConcurrentMap.

Suitable for SINGLE_NODE deployments and unit/integration tests. Lease expiry is checked lazily at every tryAcquire / extend entry — no background scheduler. Fencing tokens are issued from a single monotonic counter so any stale handle held by a former holder is trivially detectable.

Nested Class Summary

Nested classes/interfaces inherited from interface at.aimon.session.web.spi.ConversationLock

ConversationLock.LockHandle

Constructor Summary

Constructors

Constructor	Description
InMemoryConversationLock()
InMemoryConversationLock(Clock clock)

Method Summary

Modifier and Type	Method	Description
boolean	extend(ConversationLock.LockHandle handle, Duration lease)	Extends the lease of an already-held lock.
void	release(ConversationLock.LockHandle handle)	Releases the lock.
Optional<ConversationLock.LockHandle>	tryAcquire(at.aimon.core.agent.conversation.ConversationId id, String holderId, Duration lease)	Attempts to acquire the lock for id on behalf of holderId.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryConversationLock

public InMemoryConversationLock()

InMemoryConversationLock

public InMemoryConversationLock(Clock clock)

Method Details

tryAcquire

public Optional<ConversationLock.LockHandle> tryAcquire(at.aimon.core.agent.conversation.ConversationId id,
 String holderId,
 Duration lease)

Description copied from interface: ConversationLock

Attempts to acquire the lock for id on behalf of holderId.

Specified by:

tryAcquire in interface ConversationLock

Parameters:

id - the conversation to lock (must not be null)

holderId - the requesting holder identity (must not be null)

lease - requested lease duration (must not be null)

Returns:

a ConversationLock.LockHandle on success, empty if another holder owns it

extend

public boolean extend(ConversationLock.LockHandle handle,
 Duration lease)

Description copied from interface: ConversationLock

Extends the lease of an already-held lock.

Specified by:

extend in interface ConversationLock

Parameters:

handle - the lock handle returned from a prior ConversationLock.tryAcquire(at.aimon.core.agent.conversation.ConversationId, java.lang.String, java.time.Duration) (must not be null)

lease - new lease duration (must not be null)

Returns:

true when the lease was extended, false when the fencing token no longer matches (lease already expired or released)

release

public void release(ConversationLock.LockHandle handle)

Description copied from interface: ConversationLock

Releases the lock. Token mismatches are silently ignored — the manager treats release as best-effort and the lease will eventually expire.

Specified by:

release in interface ConversationLock

Parameters:

handle - the lock handle (must not be null)