Package com.tnsai.channels.routing

Class SessionRegistry

java.lang.Object

com.tnsai.channels.routing.SessionRegistry

public class SessionRegistry
extends Object

Tracks active channel sessions. A session represents an ongoing conversation between a user on a specific channel and the agent system.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	SessionRegistry.ChannelSession	Represents an active channel session.

Constructor Summary

Constructors

Constructor	Description
SessionRegistry()

Method Summary

Modifier and Type	Method	Description
Optional<SessionRegistry.ChannelSession>	get(String sessionKey)
Collection<SessionRegistry.ChannelSession>	getAll()
int	reapIdle(Duration maxIdle)	Removes sessions that have been idle longer than the given threshold.
void	remove(String sessionKey)
int	size()
void	touch(String sessionKey, String channelId, String conversationId)	Updates the last-active timestamp for a session, creating it if needed.

Methods inherited from class java.lang.Object

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

Constructor Details

SessionRegistry

public SessionRegistry()

Method Details

touch

public void touch(String sessionKey,
 String channelId,
 String conversationId)

Updates the last-active timestamp for a session, creating it if needed.

Parameters:

sessionKey - unique key (channelId:conversationId)

channelId - originating channel

conversationId - conversation within that channel

get

public Optional<SessionRegistry.ChannelSession> get(String sessionKey)

getAll

public Collection<SessionRegistry.ChannelSession> getAll()

remove

public void remove(String sessionKey)

reapIdle

public int reapIdle(Duration maxIdle)

Removes sessions that have been idle longer than the given threshold.

size

public int size()