com.aquenos.cassandra.pvarchiver.server.database

Class CassandraProviderBean

java.lang.Object

com.aquenos.cassandra.pvarchiver.server.database.CassandraProviderBean

All Implemented Interfaces:

CassandraProvider, Aware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationEventPublisherAware

public class CassandraProviderBean
extends Object
implements ApplicationEventPublisherAware, CassandraProvider, DisposableBean, InitializingBean, SmartInitializingSingleton

Cassandra provider that reads its configuration from CassandraProperties. Initialization of the cluster provided by this class is first tried in afterPropertiesSet(). If the initialization fails, a background thread is created that retries the initialization process every 30 seconds. The Cluster and the Session are closed when this bean is destroyed (usually when the application context is closed).

Author:

Sebastian Marsching

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	log Logger for this class.

Constructor Summary

Constructors

Constructor and Description
CassandraProviderBean()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	afterSingletonsInstantiated()
void	destroy()
Cluster	getCluster() Returns a reference to the Cassandra cluster.
ListenableFuture<Cluster>	getClusterFuture() Returns a future reference to the Cassandra cluster.
Session	getSession() Returns a reference to the Cassandra session.
ListenableFuture<Session>	getSessionFuture() Returns a future reference to the Cassandra session.
boolean	isInitialized() Tells whether this provider has been completely initialized.
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setCassandraProperties(CassandraProperties cassandraProperties)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.apache.commons.logging.Log log

Logger for this class.

Constructor Detail

CassandraProviderBean

public CassandraProviderBean()

Method Detail

getCluster

public Cluster getCluster()

Description copied from interface: CassandraProvider

Returns a reference to the Cassandra cluster.

Specified by:

getCluster in interface CassandraProvider

Returns:

reference to the Cassandra cluster.

See Also:

CassandraProvider.getClusterFuture()

getClusterFuture

public ListenableFuture<Cluster> getClusterFuture()

Description copied from interface: CassandraProvider

Returns a future reference to the Cassandra cluster. The returned future completes when the cluster instance become available. The future might not complete for a very long time if a connection to the cluster cannot be established. The returned future will only throw an exception if the Cassandra provider is destroyed before the cluster instance becomes available. In all other cases, the Cassandra provider will wait for a later attempt to create a cluster instance to succeed.

Specified by:

getClusterFuture in interface CassandraProvider

Returns:

future that provides access to the Cassandra cluster instance once it becomes available. The cluster will be the same one as the one returned by CassandraProvider.getCluster().

See Also:

CassandraProvider.getCluster()

isInitialized

public boolean isInitialized()

Description copied from interface: CassandraProvider

Tells whether this provider has been completely initialized. If true, CassandraProvider.getCluster() and CassandraProvider.getSession() will return a result and not throw an exception.

Please note that the provider might be destroyed after calling this method. In this case, CassandraProvider.getCluster() and CassandraProvider.getSession() might throw, even if this method returned true previously.

Specified by:

isInitialized in interface CassandraProvider

Returns:

true if this provider is ready for operation, false otherwise.

getSession

public Session getSession()

Description copied from interface: CassandraProvider

Returns a reference to the Cassandra session. The session can be used to run queries on the Cassandra cluster. The provider might bind the session to the correct keyspace so that other components can automatically operate on the keyspace without having to know the keyspace name.

Specified by:

getSession in interface CassandraProvider

Returns:

reference to the Cassandra session.

See Also:

CassandraProvider.getSessionFuture()

getSessionFuture

public ListenableFuture<Session> getSessionFuture()

Description copied from interface: CassandraProvider

Returns a future reference to the Cassandra session. The returned future completes when the session instance become available. The future might not complete for a very long time if a connection to the cluster cannot be established or the keyspace cannot be accessed. The returned future will only throw an exception if the Cassandra provider is destroyed before the session instance becomes available. In all other cases, the Cassandra provider will wait for a later attempt to create a session instance to succeed.

Specified by:

getSessionFuture in interface CassandraProvider

Returns:

future that provides access to the Cassandra session instance once it becomes available. The session will be the same one as the one returned by CassandraProvider.getSession().

See Also:

CassandraProvider.getSession()

setCassandraProperties

@Autowired
public void setCassandraProperties(CassandraProperties cassandraProperties)

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception