org.springframework.session.data.mongo

Class ReactiveMongoOperationsSessionRepository

java.lang.Object

org.springframework.session.data.mongo.ReactiveMongoOperationsSessionRepository

All Implemented Interfaces:

Aware, InitializingBean, ApplicationEventPublisherAware, org.springframework.session.ReactiveSessionRepository<MongoSession>

public class ReactiveMongoOperationsSessionRepository
extends Object
implements org.springframework.session.ReactiveSessionRepository<MongoSession>, ApplicationEventPublisherAware, InitializingBean

Author:

Greg Turnquist

Field Summary

Fields

Modifier and Type	Field and Description
static 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.

Constructor Summary

Constructors

Constructor and Description
ReactiveMongoOperationsSessionRepository(org.springframework.data.mongodb.core.ReactiveMongoOperations mongoOperations)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Do not use ReactiveIndexOperations to ensure indexes exist.
reactor.core.publisher.Mono<MongoSession>	createSession() Creates a new MongoSession that is capable of being persisted by this ReactiveSessionRepository.
reactor.core.publisher.Mono<Void>	deleteById(String id) Deletes the MongoSession with the given Session.getId() or does nothing if the MongoSession is not found.
reactor.core.publisher.Mono<MongoSession>	findById(String id) Gets the MongoSession by the Session.getId() or Mono.empty() if no MongoSession is found.
reactor.core.publisher.Mono<Void>	save(MongoSession session) Ensures the MongoSession created by ReactiveSessionRepository.createSession() is saved.
void	setApplicationEventPublisher(ApplicationEventPublisher eventPublisher)

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 String DEFAULT_COLLECTION_NAME

The default collection name for storing session.

See Also:

Constant Field Values

Constructor Detail

ReactiveMongoOperationsSessionRepository

public ReactiveMongoOperationsSessionRepository(org.springframework.data.mongodb.core.ReactiveMongoOperations mongoOperations)

Method Detail

createSession

public reactor.core.publisher.Mono<MongoSession> createSession()

Creates a new MongoSession that is capable of being persisted by this ReactiveSessionRepository.

This allows optimizations and customizations in how the MongoSession 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 org.springframework.session.ReactiveSessionRepository<MongoSession>

Returns:

a new MongoSession that is capable of being persisted by this ReactiveSessionRepository

save

public reactor.core.publisher.Mono<Void> save(MongoSession session)

Ensures the MongoSession created by ReactiveSessionRepository.createSession() is saved.

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

Specified by:

save in interface org.springframework.session.ReactiveSessionRepository<MongoSession>

Parameters:

session - the MongoSession to save

findById

public reactor.core.publisher.Mono<MongoSession> findById(String id)

Gets the MongoSession by the Session.getId() or Mono.empty() if no MongoSession is found.

Specified by:

findById in interface org.springframework.session.ReactiveSessionRepository<MongoSession>

Parameters:

id - the Session.getId() to lookup

Returns:

the MongoSession by the Session.getId() or Mono.empty() if no MongoSession is found.

deleteById

public reactor.core.publisher.Mono<Void> deleteById(String id)

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

Specified by:

deleteById in interface org.springframework.session.ReactiveSessionRepository<MongoSession>

Parameters:

id - the Session.getId() to delete

afterPropertiesSet

public void afterPropertiesSet()

Do not use ReactiveIndexOperations to ensure indexes exist. Instead, get a blocking IndexOperations and use that instead, if possible.

Specified by:

afterPropertiesSet in interface InitializingBean

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher eventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware