Package org.springframework.data.cassandra.core.cql.session

Class DefaultReactiveSessionFactory

java.lang.Object

org.springframework.data.cassandra.core.cql.session.DefaultReactiveSessionFactory

All Implemented Interfaces:

ReactiveSessionFactory

public class DefaultReactiveSessionFactory
extends Object
implements ReactiveSessionFactory

Default implementation of ReactiveSessionFactory.

This implementation returns always the same ReactiveSession.

Since:

2.0

Author:

Mark Paluch

Constructor Summary

Constructors

Constructor	Description
DefaultReactiveSessionFactory(ReactiveSession session)	Create a new ReactiveRowMapperResultSetExtractor.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<ReactiveSession>	getSession()	Return a ReactiveSession to be used directly or inside a callback inside ReactiveCqlTemplate.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultReactiveSessionFactory

public DefaultReactiveSessionFactory(ReactiveSession session)

Create a new ReactiveRowMapperResultSetExtractor.

Parameters:

session - the ReactiveSession provides connections to Cassandra, must not be null.

Method Details

getSession

public reactor.core.publisher.Mono<ReactiveSession> getSession()

Description copied from interface: ReactiveSessionFactory

Return a ReactiveSession to be used directly or inside a callback inside ReactiveCqlTemplate.

Specified by:

getSession in interface ReactiveSessionFactory

Returns:

a ReactiveSession.