org.springframework.data.cassandra.config

Class AbstractReactiveCassandraConfiguration

java.lang.Object

org.springframework.data.cassandra.config.AbstractSessionConfiguration

org.springframework.data.cassandra.config.AbstractCassandraConfiguration

org.springframework.data.cassandra.config.AbstractReactiveCassandraConfiguration

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware

public abstract class AbstractReactiveCassandraConfiguration
extends AbstractCassandraConfiguration

Extension to AbstractCassandraConfiguration providing Spring Data Cassandra configuration for Spring Data's Reactive Cassandra support using JavaConfig.

Since:

2.0

Author:

Mark Paluch

Constructor Summary

Constructors

Constructor and Description
AbstractReactiveCassandraConfiguration()

Method Summary

Modifier and Type	Method and Description
ReactiveSession	reactiveCassandraSession() Creates a ReactiveSession object.
ReactiveSessionFactory	reactiveCassandraSessionFactory() Creates a ReactiveSessionFactory to be used by the ReactiveCassandraTemplate.
ReactiveCassandraTemplate	reactiveCassandraTemplate() Creates a CassandraAdminTemplate.
ReactiveCqlTemplate	reactiveCqlTemplate() Creates a ReactiveCqlTemplate using the configured ReactiveSessionFactory.
void	setBeanFactory(BeanFactory beanFactory) Configures a reference to the BeanFactory.

Methods inherited from class org.springframework.data.cassandra.config.AbstractCassandraConfiguration

cassandraConverter, cassandraMapping, cassandraSessionFactory, cassandraTemplate, customConversions, getBeanClassLoader, getEntityBasePackages, getInitialEntitySet, getRequiredSessionFactory, getSchemaAction, keyspaceCleaner, keyspacePopulator, scriptOf, setBeanClassLoader

Methods inherited from class org.springframework.data.cassandra.config.AbstractSessionConfiguration

cassandraSession, cqlTemplate, getBeanFactory, getClusterName, getCompressionType, getContactPoints, getDriverConfigLoaderBuilderConfigurer, getDriverConfigurationResource, getKeyspaceCreations, getKeyspaceDrops, getKeyspaceName, getLocalDataCenter, getPort, getRequiredSession, getSessionBuilderConfigurer, getSessionName, getShutdownScripts, getStartupScripts, requireBeanOfType

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractReactiveCassandraConfiguration

public AbstractReactiveCassandraConfiguration()

Method Detail

reactiveCassandraSession

@Bean
public ReactiveSession reactiveCassandraSession()

Creates a ReactiveSession object. This wraps a CqlSession to expose Cassandra access in a reactive style.

Returns:

the ReactiveSession.

See Also:

AbstractSessionConfiguration.cassandraSession(), DefaultBridgedReactiveSession

reactiveCassandraSessionFactory

@Bean
public ReactiveSessionFactory reactiveCassandraSessionFactory()

Creates a ReactiveSessionFactory to be used by the ReactiveCassandraTemplate. Uses the ReactiveSession instance configured in reactiveCassandraSession().

Returns:

the ReactiveSessionFactory.

See Also:

reactiveCassandraSession(), reactiveCassandraTemplate()

reactiveCassandraTemplate

@Bean
public ReactiveCassandraTemplate reactiveCassandraTemplate()

Creates a CassandraAdminTemplate.

Returns:

the ReactiveCassandraTemplate.

See Also:

reactiveCassandraSessionFactory(), AbstractCassandraConfiguration.cassandraConverter()

reactiveCqlTemplate

@Bean
public ReactiveCqlTemplate reactiveCqlTemplate()

Creates a ReactiveCqlTemplate using the configured ReactiveSessionFactory.

Returns:

the ReactiveCqlOperations.

See Also:

reactiveCassandraSessionFactory()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Description copied from class: AbstractSessionConfiguration

Configures a reference to the BeanFactory.

Specified by:

setBeanFactory in interface BeanFactoryAware

Overrides:

setBeanFactory in class AbstractSessionConfiguration

Parameters:

beanFactory - reference to the BeanFactory.

Throws:

BeansException - if the BeanFactory could not be initialized.

See Also:

BeanFactory