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

Class CassandraAppClusterConfiguration

java.lang.Object

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

@Configuration
 @EnableConfigurationProperties(value=CassandraClusterProperties.class)
 @Import(value=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 and Description
CassandraAppClusterConfiguration()

Method Summary

Modifier and Type	Method and 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 Detail

CassandraAppClusterConfiguration

public CassandraAppClusterConfiguration()

Method Detail

clusterBuilderCustomizer

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

keyspaceCreator

@Bean
 @ConditionalOnProperty(value="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(value="keyspaceCreator")
public com.datastax.oss.driver.api.core.CqlSession cassandraSession(com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder)

keyspaceInitializer

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

Throws:

IOException