org.springframework.session.data.mongo

Class MongoOperationsSessionRepository

java.lang.Object

org.springframework.session.data.mongo.MongoOperationsSessionRepository

All Implemented Interfaces:

FindByIndexNameSessionRepository<MongoExpiringSession>, SessionRepository<MongoExpiringSession>

public class MongoOperationsSessionRepository
extends java.lang.Object
implements FindByIndexNameSessionRepository<MongoExpiringSession>

Session repository implementation which stores sessions in Mongo. Uses AbstractMongoSessionConverter to transform session objects from/to native Mongo representation (DBObject). Repository is also responsible for removing expired sessions from database. Cleanup is done every minute.

Since:

1.2

Author:

Jakub Kubrynski

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_COLLECTION_NAME the default collection name for storing session.
static int	DEFAULT_INACTIVE_INTERVAL The default time period in seconds in which a session will expire.

Fields inherited from interface org.springframework.session.FindByIndexNameSessionRepository

PRINCIPAL_NAME_INDEX_NAME

Constructor Summary

Constructors

Constructor and Description
MongoOperationsSessionRepository(org.springframework.data.mongodb.core.MongoOperations mongoOperations)

Method Summary

Modifier and Type	Method and Description
MongoExpiringSession	createSession() Creates a new Session that is capable of being persisted by this SessionRepository.
void	delete(java.lang.String id) Deletes the Session with the given Session.getId() or does nothing if the Session is not found.
void	ensureIndexesAreCreated()
java.util.Map<java.lang.String,MongoExpiringSession>	findByIndexNameAndIndexValue(java.lang.String indexName, java.lang.String indexValue) Currently this repository allows only querying against PRINCIPAL_NAME_INDEX_NAME.
MongoExpiringSession	getSession(java.lang.String id) Gets the Session by the Session.getId() or null if no Session is found.
void	save(MongoExpiringSession session) Ensures the Session created by SessionRepository.createSession() is saved.
void	setCollectionName(java.lang.String collectionName)
void	setMaxInactiveIntervalInSeconds(java.lang.Integer maxInactiveIntervalInSeconds)
void	setMongoSessionConverter(AbstractMongoSessionConverter mongoSessionConverter)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_INACTIVE_INTERVAL

public static final int DEFAULT_INACTIVE_INTERVAL

The default time period in seconds in which a session will expire.

See Also:

Constant Field Values

DEFAULT_COLLECTION_NAME

public static final java.lang.String DEFAULT_COLLECTION_NAME

the default collection name for storing session.

See Also:

Constant Field Values

Constructor Detail

MongoOperationsSessionRepository

public MongoOperationsSessionRepository(org.springframework.data.mongodb.core.MongoOperations mongoOperations)

Method Detail

createSession

public MongoExpiringSession createSession()

Description copied from interface: SessionRepository

Creates a new Session that is capable of being persisted by this SessionRepository.

This allows optimizations and customizations in how the Session is persisted. For example, the implementation returned might keep track of the changes ensuring that only the delta needs to be persisted on a save.

Specified by:

createSession in interface SessionRepository<MongoExpiringSession>

Returns:

a new Session that is capable of being persisted by this SessionRepository

save

public void save(MongoExpiringSession session)

Description copied from interface: SessionRepository

Ensures the Session created by SessionRepository.createSession() is saved.

Some implementations may choose to save as the Session is updated by returning a Session that immediately persists any changes. In this case, this method may not actually do anything.

Specified by:

save in interface SessionRepository<MongoExpiringSession>

Parameters:

session - the Session to save

getSession

public MongoExpiringSession getSession(java.lang.String id)

Description copied from interface: SessionRepository

Gets the Session by the Session.getId() or null if no Session is found.

Specified by:

getSession in interface SessionRepository<MongoExpiringSession>

Parameters:

id - the Session.getId() to lookup

Returns:

the Session by the Session.getId() or null if no Session is found.

findByIndexNameAndIndexValue

public java.util.Map<java.lang.String,MongoExpiringSession> findByIndexNameAndIndexValue(java.lang.String indexName,
                                                                                         java.lang.String indexValue)

Currently this repository allows only querying against PRINCIPAL_NAME_INDEX_NAME.

Specified by:

findByIndexNameAndIndexValue in interface FindByIndexNameSessionRepository<MongoExpiringSession>

Parameters:

indexName - the name if the index (i.e. FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME)

indexValue - the value of the index to search for.

Returns:

sessions map

delete

public void delete(java.lang.String id)

Description copied from interface: SessionRepository

Deletes the Session with the given Session.getId() or does nothing if the Session is not found.

Specified by:

delete in interface SessionRepository<MongoExpiringSession>

Parameters:

id - the Session.getId() to delete

ensureIndexesAreCreated

@PostConstruct
public void ensureIndexesAreCreated()

setMongoSessionConverter

public void setMongoSessionConverter(AbstractMongoSessionConverter mongoSessionConverter)

setMaxInactiveIntervalInSeconds

public void setMaxInactiveIntervalInSeconds(java.lang.Integer maxInactiveIntervalInSeconds)

setCollectionName

public void setCollectionName(java.lang.String collectionName)