io.micronaut.configuration.cassandra

Class CassandraSessionFactory

java.lang.Object

io.micronaut.configuration.cassandra.CassandraSessionFactory

All Implemented Interfaces:

java.lang.AutoCloseable

@Factory
public class CassandraSessionFactory
extends java.lang.Object
implements java.lang.AutoCloseable

Creates cassandra cluster for each configuration bean.

Since:

1.0

Author:

Nirav Assar, Michael Pollind

Constructor Summary

Constructors

Constructor and Description
CassandraSessionFactory(io.micronaut.core.value.PropertyResolver propertyResolver) Default constructor.

Method Summary

Modifier and Type	Method and Description
com.datastax.oss.driver.api.core.CqlSession	cassandraCluster(com.datastax.oss.driver.api.core.CqlSessionBuilder builder) Creates the CqlSession bean for the given configuration.
void	close() closes all active CqlSession.
com.datastax.oss.driver.api.core.CqlSessionBuilder	session(CassandraConfiguration configuration) Creates the CqlSessionBuilder bean for the given configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraSessionFactory

public CassandraSessionFactory(io.micronaut.core.value.PropertyResolver propertyResolver)

Default constructor.

Parameters:

propertyResolver - Property resolve for application configurations

Method Detail

session

@EachBean(value=CassandraConfiguration.class)
public com.datastax.oss.driver.api.core.CqlSessionBuilder session(CassandraConfiguration configuration)

Creates the CqlSessionBuilder bean for the given configuration.

Parameters:

configuration - The cassandra configuration bean

Returns:

A CqlSession bean

cassandraCluster

@EachBean(value=com.datastax.oss.driver.api.core.CqlSessionBuilder.class)
 @Bean(preDestroy="close")
public com.datastax.oss.driver.api.core.CqlSession cassandraCluster(com.datastax.oss.driver.api.core.CqlSessionBuilder builder)

Creates the CqlSession bean for the given configuration.

Parameters:

builder - The CqlSessionBuilder

Returns:

A CqlSession bean

close

@PreDestroy
public void close()

closes all active CqlSession.

Specified by:

close in interface java.lang.AutoCloseable