org.wildfly.clustering.web.infinispan.session

Class InfinispanSessionManager<MV,AV,L>

java.lang.Object

org.wildfly.clustering.web.infinispan.session.InfinispanSessionManager<MV,AV,L>

All Implemented Interfaces:

IdentifierFactory<String>, ActiveSessionStatistics, SessionManager<L,TransactionBatch>

public class InfinispanSessionManager<MV,AV,L>
extends Object
implements SessionManager<L,TransactionBatch>

Generic session manager implementation - independent of cache mapping strategy.

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
InfinispanSessionManager(SessionFactory<MV,AV,L> factory, InfinispanSessionManagerConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
void	activated(org.infinispan.notifications.cachelistener.event.CacheEntryActivatedEvent<SessionCreationMetaDataKey,?> event)
boolean	containsSession(String id) Indicates whether or not the session with the specified identifier is known to this session manager.
String	createIdentifier()
Session<L>	createSession(String id) Returns the session with the specified identifier, creating one if necessary Sessions returned by this method must be closed via Session.close().
void	dataRehashed(org.infinispan.notifications.cachelistener.event.DataRehashedEvent<SessionCreationMetaDataKey,?> event)
Session<L>	findSession(String id) Returns the session with the specified identifier, or null if none exists.
long	getActiveSessionCount()
Set<String>	getActiveSessions() Returns the identifiers of those sessions that are active on this node.
Batcher<TransactionBatch>	getBatcher() Exposes the batching mechanism used by this session manager.
Duration	getDefaultMaxInactiveInterval() Returns the default maximum inactive interval, as a duration, for all sessions created by this session manager.
Set<String>	getLocalSessions() Returns the identifiers of all sessions on this node, including both active and passive sessions.
int	getMaxActiveSessions()
void	passivated(org.infinispan.notifications.cachelistener.event.CacheEntryPassivatedEvent<SessionCreationMetaDataKey,?> event)
void	removed(org.infinispan.notifications.cachelistener.event.CacheEntryRemovedEvent<SessionCreationMetaDataKey,?> event)
void	setDefaultMaxInactiveInterval(Duration duration) Set the default maximum inactive interval, using the specified time duration, for all sessions created by this session manager.
void	start()
void	stop()
ImmutableSession	viewSession(String id) Returns a read-only view of the session with the specified identifier.

Methods inherited from class java.lang.Object

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

Constructor Detail

InfinispanSessionManager

public InfinispanSessionManager(SessionFactory<MV,AV,L> factory,
                                InfinispanSessionManagerConfiguration configuration)

Method Detail

start

public void start()

Specified by:

start in interface IdentifierFactory<String>

stop

public void stop()

Specified by:

stop in interface IdentifierFactory<String>

getBatcher

public Batcher<TransactionBatch> getBatcher()

Description copied from interface: SessionManager

Exposes the batching mechanism used by this session manager.

Specified by:

getBatcher in interface SessionManager<L,TransactionBatch>

Returns:

a batcher.

getDefaultMaxInactiveInterval

public Duration getDefaultMaxInactiveInterval()

Description copied from interface: SessionManager

Returns the default maximum inactive interval, as a duration, for all sessions created by this session manager.

Specified by:

getDefaultMaxInactiveInterval in interface SessionManager<L,TransactionBatch>

Returns:

a duration

setDefaultMaxInactiveInterval

public void setDefaultMaxInactiveInterval(Duration duration)

Description copied from interface: SessionManager

Set the default maximum inactive interval, using the specified time duration, for all sessions created by this session manager.

Specified by:

setDefaultMaxInactiveInterval in interface SessionManager<L,TransactionBatch>

Parameters:

duration - a time duration

createIdentifier

public String createIdentifier()

Specified by:

createIdentifier in interface IdentifierFactory<String>

containsSession

public boolean containsSession(String id)

Description copied from interface: SessionManager

Indicates whether or not the session with the specified identifier is known to this session manager.

Specified by:

containsSession in interface SessionManager<L,TransactionBatch>

Parameters:

id - a unique session identifier

Returns:

true, if the session is known to the manager, false otherwise

findSession

public Session<L> findSession(String id)

Description copied from interface: SessionManager

Returns the session with the specified identifier, or null if none exists. Sessions returned by this method must be closed via Session.close(). This method is intended to be invoked within the context of a batch.

Specified by:

findSession in interface SessionManager<L,TransactionBatch>

Parameters:

id - a session identifier

Returns:

an existing web session, or null if none exists

createSession

public Session<L> createSession(String id)

Description copied from interface: SessionManager

Returns the session with the specified identifier, creating one if necessary Sessions returned by this method must be closed via Session.close(). This method is intended to be invoked within the context of a batch.

Specified by:

createSession in interface SessionManager<L,TransactionBatch>

Parameters:

id - a session identifier

Returns:

a new or existing web session

viewSession

public ImmutableSession viewSession(String id)

Description copied from interface: SessionManager

Returns a read-only view of the session with the specified identifier. This method is intended to be invoked within the context of a batch

Specified by:

viewSession in interface SessionManager<L,TransactionBatch>

Parameters:

id - a unique session identifier

Returns:

a read-only session or null if none exists

getActiveSessions

public Set<String> getActiveSessions()

Description copied from interface: SessionManager

Returns the identifiers of those sessions that are active on this node.

Specified by:

getActiveSessions in interface SessionManager<L,TransactionBatch>

Returns:

a set of session identifiers.

getLocalSessions

public Set<String> getLocalSessions()

Description copied from interface: SessionManager

Returns the identifiers of all sessions on this node, including both active and passive sessions.

Specified by:

getLocalSessions in interface SessionManager<L,TransactionBatch>

Returns:

a set of session identifiers.

getMaxActiveSessions

public int getMaxActiveSessions()

Specified by:

getMaxActiveSessions in interface ActiveSessionStatistics

Returns:

the maximum number of active sessions allowed by this session manager

getActiveSessionCount

public long getActiveSessionCount()

Specified by:

getActiveSessionCount in interface ActiveSessionStatistics

Returns:

The number of active sessions

activated

public void activated(org.infinispan.notifications.cachelistener.event.CacheEntryActivatedEvent<SessionCreationMetaDataKey,?> event)

passivated

public void passivated(org.infinispan.notifications.cachelistener.event.CacheEntryPassivatedEvent<SessionCreationMetaDataKey,?> event)

removed

public void removed(org.infinispan.notifications.cachelistener.event.CacheEntryRemovedEvent<SessionCreationMetaDataKey,?> event)

dataRehashed

public void dataRehashed(org.infinispan.notifications.cachelistener.event.DataRehashedEvent<SessionCreationMetaDataKey,?> event)