Package org.springframework.cloud.fn.consumer.cassandra.cluster

Class CassandraAppClusterConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.cassandra.cluster.CassandraAppClusterConfiguration

@Configuration
@EnableConfigurationProperties(CassandraClusterProperties.class)
@Import(org.springframework.cloud.fn.consumer.cassandra.cluster.CassandraAppClusterConfiguration.CassandraPackageRegistrar.class)
public class CassandraAppClusterConfiguration
extends Object

Author:

Artem Bilan, Thomas Risberg, Rob Hardt

Constructor Summary

Constructors

Constructor	Description
CassandraAppClusterConfiguration()

Method Summary

Modifier and Type	Method	Description
com.datastax.oss.driver.api.core.CqlSession	cassandraSession(com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder)
org.springframework.boot.autoconfigure.cassandra.CqlSessionBuilderCustomizer	clusterBuilderCustomizer(CassandraClusterProperties cassandraClusterProperties)
Object	keyspaceCreator(org.springframework.boot.autoconfigure.cassandra.CassandraProperties cassandraProperties, com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder)
Object	keyspaceInitializer(CassandraClusterProperties cassandraClusterProperties, org.springframework.data.cassandra.core.ReactiveCassandraTemplate reactiveCassandraTemplate)

Methods inherited from class java.lang.Object

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

Constructor Details

CassandraAppClusterConfiguration

public CassandraAppClusterConfiguration()

Method Details

clusterBuilderCustomizer

@Bean
public org.springframework.boot.autoconfigure.cassandra.CqlSessionBuilderCustomizer clusterBuilderCustomizer(CassandraClusterProperties cassandraClusterProperties)

keyspaceCreator

@Bean
@ConditionalOnProperty("cassandra.cluster.create-keyspace")
public Object keyspaceCreator(org.springframework.boot.autoconfigure.cassandra.CassandraProperties cassandraProperties,
 com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder)

cassandraSession

@Bean
@Lazy
@DependsOn("keyspaceCreator")
public com.datastax.oss.driver.api.core.CqlSession cassandraSession(com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder)

keyspaceInitializer

@Bean
@ConditionalOnProperty("cassandra.cluster.init-script")
public Object keyspaceInitializer(CassandraClusterProperties cassandraClusterProperties,
 org.springframework.data.cassandra.core.ReactiveCassandraTemplate reactiveCassandraTemplate)
                           throws IOException

Throws:

IOException