org.springframework.session.data.gemfire

Class AbstractGemFireOperationsSessionRepository

java.lang.Object

com.gemstone.gemfire.cache.util.CacheListenerAdapter<Object,ExpiringSession>

org.springframework.session.data.gemfire.AbstractGemFireOperationsSessionRepository

All Implemented Interfaces:

com.gemstone.gemfire.cache.CacheCallback, com.gemstone.gemfire.cache.CacheListener<Object,ExpiringSession>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationEventPublisherAware, FindByIndexNameSessionRepository<ExpiringSession>, SessionRepository<ExpiringSession>

Direct Known Subclasses:

GemFireOperationsSessionRepository

public abstract class AbstractGemFireOperationsSessionRepository
extends com.gemstone.gemfire.cache.util.CacheListenerAdapter<Object,ExpiringSession>
implements org.springframework.beans.factory.InitializingBean, FindByIndexNameSessionRepository<ExpiringSession>, org.springframework.context.ApplicationEventPublisherAware

AbstractGemFireOperationsSessionRepository is an abstract base class encapsulating functionality common to all implementations that support SessionRepository operations backed by GemFire.

Since:

1.1.0

Author:

John Blum

See Also:

InitializingBean, ApplicationEventPublisherAware, ExpiringSession, FindByIndexNameSessionRepository, EnableGemFireHttpSession, CacheListenerAdapter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractGemFireOperationsSessionRepository.GemFireSession GemFireSession is a GemFire representation model of a Spring ExpiringSession that stores and manages Session state information in GemFire.
static class	AbstractGemFireOperationsSessionRepository.GemFireSessionAttributes The GemFireSessionAttributes class is a container for Session attributes implementing both the DataSerializable and Delta GemFire interfaces for efficient storage and distribution (replication) in GemFire.
static class	AbstractGemFireOperationsSessionRepository.GemFireSessionAttributesInstantiator GemFireSessionAttributesInstantiator is a GemFire Instantiator use to instantiate instances of the AbstractGemFireOperationsSessionRepository.GemFireSessionAttributes object used in GemFire's data serialization framework when persisting Session attributes state in GemFire.
static class	AbstractGemFireOperationsSessionRepository.GemFireSessionInstantiator GemFireSessionInstantiator is a GemFire Instantiator use to instantiate instances of the AbstractGemFireOperationsSessionRepository.GemFireSession object used in GemFire's data serialization framework when persisting Session state in GemFire.

Field Summary

Fields

Modifier and Type	Field and Description
protected Log	logger

Fields inherited from interface org.springframework.session.FindByIndexNameSessionRepository

PRINCIPAL_NAME_INDEX_NAME

Constructor Summary

Constructors

Constructor and Description
AbstractGemFireOperationsSessionRepository(org.springframework.data.gemfire.GemfireOperations template) Constructs an instance of AbstractGemFireOperationsSessionRepository with a required GemfireOperations instance used to perform GemFire data access operations and interactions supporting the SessionRepository operations.

Method Summary

Modifier and Type	Method and Description
void	afterCreate(com.gemstone.gemfire.cache.EntryEvent<Object,ExpiringSession> event) Callback method triggered when an entry is created in the GemFire cache Region.
void	afterDestroy(com.gemstone.gemfire.cache.EntryEvent<Object,ExpiringSession> event) Callback method triggered when an entry is destroyed in the GemFire cache Region.
void	afterInvalidate(com.gemstone.gemfire.cache.EntryEvent<Object,ExpiringSession> event) Callback method triggered when an entry is invalidated in the GemFire cache Region.
void	afterPropertiesSet() Callback method during Spring bean initialization that will capture the fully-qualified name of the GemFire cache Region used to manage Session state and register this SessionRepository as a GemFire CacheListener.
protected ExpiringSession	delete(Session session) Deletes the given Session from GemFire.
protected org.springframework.context.ApplicationEventPublisher	getApplicationEventPublisher() Gets the ApplicationEventPublisher used to publish Session events corresponding to GemFire cache events.
protected String	getFullyQualifiedRegionName() Gets the fully-qualified name of the GemFire cache Region used to store and manage Session data.
int	getMaxInactiveIntervalInSeconds() Gets the maximum interval in seconds in which a Session can remain inactive before it is considered expired.
org.springframework.data.gemfire.GemfireOperations	getTemplate() Gets a reference to the GemfireOperations (template) used to perform data access operations and other interactions on the GemFire cache Region backing this SessionRepository.
protected void	handleCreated(String sessionId, ExpiringSession session) Causes Session created events to be published to the Spring application context.
protected void	handleDeleted(String sessionId, ExpiringSession session) Causes Session deleted events to be published to the Spring application context.
protected void	handleDestroyed(String sessionId, ExpiringSession session) Causes Session destroyed events to be published to the Spring application context.
protected void	handleExpired(String sessionId, ExpiringSession session) Causes Session expired events to be published to the Spring application context.
protected void	publishEvent(org.springframework.context.ApplicationEvent event) Publishes the specified ApplicationEvent to the Spring application context.
void	setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher) Sets the ApplicationEventPublisher used to publish Session events corresponding to GemFire cache events.
void	setMaxInactiveIntervalInSeconds(int maxInactiveIntervalInSeconds) Sets the maximum interval in seconds in which a Session can remain inactive before it is considered expired.
protected <T extends ExpiringSession> T	touch(T expiringSession) Updates the ExpiringSession.setLastAccessedTime(long) property of the ExpiringSession.

Methods inherited from class com.gemstone.gemfire.cache.util.CacheListenerAdapter

afterRegionClear, afterRegionCreate, afterRegionDestroy, afterRegionInvalidate, afterRegionLive, afterUpdate, close

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.session.FindByIndexNameSessionRepository

findByIndexNameAndIndexValue

Methods inherited from interface org.springframework.session.SessionRepository

createSession, delete, getSession, save

Field Detail

logger

protected final Log logger

Constructor Detail

AbstractGemFireOperationsSessionRepository

public AbstractGemFireOperationsSessionRepository(org.springframework.data.gemfire.GemfireOperations template)

Constructs an instance of AbstractGemFireOperationsSessionRepository with a required GemfireOperations instance used to perform GemFire data access operations and interactions supporting the SessionRepository operations.

Parameters:

template - the GemfireOperations instance used to interact with GemFire.

See Also:

GemfireOperations

Method Detail

setApplicationEventPublisher

public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)

Sets the ApplicationEventPublisher used to publish Session events corresponding to GemFire cache events.

Specified by:

setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware

Parameters:

applicationEventPublisher - the Spring ApplicationEventPublisher used to publish Session-based events.

See Also:

ApplicationEventPublisher

getApplicationEventPublisher

protected org.springframework.context.ApplicationEventPublisher getApplicationEventPublisher()

Gets the ApplicationEventPublisher used to publish Session events corresponding to GemFire cache events.

Returns:

the Spring ApplicationEventPublisher used to publish Session-based events.

See Also:

ApplicationEventPublisher

getFullyQualifiedRegionName

protected String getFullyQualifiedRegionName()

Gets the fully-qualified name of the GemFire cache Region used to store and manage Session data.

Returns:

a String indicating the fully qualified name of the GemFire cache Region used to store and manage Session data.

setMaxInactiveIntervalInSeconds

public void setMaxInactiveIntervalInSeconds(int maxInactiveIntervalInSeconds)

Sets the maximum interval in seconds in which a Session can remain inactive before it is considered expired.

Parameters:

maxInactiveIntervalInSeconds - an integer value specifying the maximum interval in seconds that a Session can remain inactive before it is considered expired.

getMaxInactiveIntervalInSeconds

public int getMaxInactiveIntervalInSeconds()

Gets the maximum interval in seconds in which a Session can remain inactive before it is considered expired.

Returns:

an integer value specifying the maximum interval in seconds that a Session can remain inactive before it is considered expired.

getTemplate

public org.springframework.data.gemfire.GemfireOperations getTemplate()

Gets a reference to the GemfireOperations (template) used to perform data access operations and other interactions on the GemFire cache Region backing this SessionRepository.

Returns:

a reference to the GemfireOperations used to interact with GemFire.

See Also:

GemfireOperations

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Callback method during Spring bean initialization that will capture the fully-qualified name of the GemFire cache Region used to manage Session state and register this SessionRepository as a GemFire CacheListener. Additionally, this method registers GemFire Instantiators for the AbstractGemFireOperationsSessionRepository.GemFireSession and AbstractGemFireOperationsSessionRepository.GemFireSessionAttributes types to optimize GemFire's instantiation logic on deserialization using the data serialization framework when accessing the Session's state stored in GemFire.

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception - if an error occurs during the initialization process.

afterCreate

public void afterCreate(com.gemstone.gemfire.cache.EntryEvent<Object,ExpiringSession> event)

Callback method triggered when an entry is created in the GemFire cache Region.

Specified by:

afterCreate in interface com.gemstone.gemfire.cache.CacheListener<Object,ExpiringSession>

Overrides:

afterCreate in class com.gemstone.gemfire.cache.util.CacheListenerAdapter<Object,ExpiringSession>

Parameters:

event - EntryEvent containing the details of the cache Region operation.

See Also:

EntryEvent, handleCreated(String, ExpiringSession)

afterDestroy

public void afterDestroy(com.gemstone.gemfire.cache.EntryEvent<Object,ExpiringSession> event)

Callback method triggered when an entry is destroyed in the GemFire cache Region.

Specified by:

afterDestroy in interface com.gemstone.gemfire.cache.CacheListener<Object,ExpiringSession>

Overrides:

afterDestroy in class com.gemstone.gemfire.cache.util.CacheListenerAdapter<Object,ExpiringSession>

Parameters:

event - an EntryEvent containing the details of the cache operation.

See Also:

EntryEvent, handleDestroyed(String, ExpiringSession)

afterInvalidate

public void afterInvalidate(com.gemstone.gemfire.cache.EntryEvent<Object,ExpiringSession> event)

Callback method triggered when an entry is invalidated in the GemFire cache Region.

Specified by:

afterInvalidate in interface com.gemstone.gemfire.cache.CacheListener<Object,ExpiringSession>

Overrides:

afterInvalidate in class com.gemstone.gemfire.cache.util.CacheListenerAdapter<Object,ExpiringSession>

Parameters:

event - an EntryEvent containing the details of the cache operation.

See Also:

EntryEvent, handleExpired(String, ExpiringSession)

delete

protected ExpiringSession delete(Session session)

Deletes the given Session from GemFire.

Parameters:

session - Session to delete.

Returns:

null.

See Also:

Session, SessionRepository.delete(String)

handleCreated

protected void handleCreated(String sessionId,
                             ExpiringSession session)

Causes Session created events to be published to the Spring application context.

Parameters:

sessionId - a String indicating the ID of the Session.

session - a reference to the Session triggering the event.

See Also:

SessionCreatedEvent, ExpiringSession, publishEvent(ApplicationEvent)

handleDeleted

protected void handleDeleted(String sessionId,
                             ExpiringSession session)

Causes Session deleted events to be published to the Spring application context.

Parameters:

sessionId - a String indicating the ID of the Session.

session - a reference to the Session triggering the event.

See Also:

SessionDeletedEvent, ExpiringSession, publishEvent(ApplicationEvent)

handleDestroyed

protected void handleDestroyed(String sessionId,
                               ExpiringSession session)

Causes Session destroyed events to be published to the Spring application context.

Parameters:

sessionId - a String indicating the ID of the Session.

session - a reference to the Session triggering the event.

See Also:

SessionDestroyedEvent, ExpiringSession, publishEvent(ApplicationEvent)

handleExpired

protected void handleExpired(String sessionId,
                             ExpiringSession session)

Causes Session expired events to be published to the Spring application context.

Parameters:

sessionId - a String indicating the ID of the Session.

session - a reference to the Session triggering the event.

See Also:

SessionExpiredEvent, ExpiringSession, publishEvent(ApplicationEvent)

publishEvent

protected void publishEvent(org.springframework.context.ApplicationEvent event)

Publishes the specified ApplicationEvent to the Spring application context.

Parameters:

event - the ApplicationEvent to publish.

See Also:

ApplicationEventPublisher.publishEvent(ApplicationEvent), ApplicationEvent

touch

protected <T extends ExpiringSession> T touch(T expiringSession)

Updates the ExpiringSession.setLastAccessedTime(long) property of the ExpiringSession.

Type Parameters:

T - Class sub-type of the ExpiringSession.

Parameters:

expiringSession - ExpiringSession to touch.

Returns:

the ExpiringSession.

See Also:

ExpiringSession.setLastAccessedTime(long)