org.wildfly.clustering.web.infinispan.session

Class InfinispanSessionManager<V,L>

java.lang.Object

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

All Implemented Interfaces:

org.infinispan.notifications.KeyFilter, IdentifierFactory<String>, SessionManager<L>

public class InfinispanSessionManager<V,L>
extends Object
implements SessionManager<L>, org.infinispan.notifications.KeyFilter

Generic session manager implementation - independent of cache mapping strategy.

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
InfinispanSessionManager(SessionContext context, IdentifierFactory<String> identifierFactory, org.infinispan.Cache<String,V> cache, SessionFactory<V,L> factory, Batcher batcher, org.jboss.metadata.web.jboss.JBossWebMetaData metaData)

Method Summary

Modifier and Type	Method and Description
boolean	accept(Object key)
void	activated(org.infinispan.notifications.cachelistener.event.CacheEntryActivatedEvent<String,?> 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().
Session<L>	findSession(String id) Returns the session with the specified identifier, or null if none exists.
Set<String>	getActiveSessions() Returns the identifiers of those sessions that are active on this node.
Batcher	getBatcher() Exposes the batching mechanism used by this session manager.
long	getDefaultMaxInactiveInterval(TimeUnit unit) Returns the default maximum inactive interval, using the specified unit, 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.
void	passivated(org.infinispan.notifications.cachelistener.event.CacheEntryPassivatedEvent<String,?> event)
void	removed(org.infinispan.notifications.cachelistener.event.CacheEntryRemovedEvent<String,?> event)
void	setDefaultMaxInactiveInterval(long value, TimeUnit unit) Set the default maximum inactive interval, using the specified unit, for all sessions created by this session manager.
void	start()
void	stop()
void	topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<String,?> event)
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(SessionContext context,
                                IdentifierFactory<String> identifierFactory,
                                org.infinispan.Cache<String,V> cache,
                                SessionFactory<V,L> factory,
                                Batcher batcher,
                                org.jboss.metadata.web.jboss.JBossWebMetaData metaData)

Method Detail

start

public void start()

Specified by:

start in interface IdentifierFactory<String>

stop

public void stop()

Specified by:

stop in interface IdentifierFactory<String>

accept

public boolean accept(Object key)

Specified by:

accept in interface org.infinispan.notifications.KeyFilter

getBatcher

public Batcher getBatcher()

Description copied from interface: SessionManager

Exposes the batching mechanism used by this session manager.

Specified by:

getBatcher in interface SessionManager<L>

Returns:

a batcher.

getDefaultMaxInactiveInterval

public long getDefaultMaxInactiveInterval(TimeUnit unit)

Description copied from interface: SessionManager

Returns the default maximum inactive interval, using the specified unit, for all sessions created by this session manager.

Specified by:

getDefaultMaxInactiveInterval in interface SessionManager<L>

Parameters:

unit - a time unit

Returns:

a time interval

setDefaultMaxInactiveInterval

public void setDefaultMaxInactiveInterval(long value,
                                          TimeUnit unit)

Description copied from interface: SessionManager

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

Specified by:

setDefaultMaxInactiveInterval in interface SessionManager<L>

unit - a time unit

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>

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>

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>

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>

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>

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>

Returns:

a set of session identifiers.

activated

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

passivated

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

removed

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

topologyChanged

public void topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<String,?> event)