org.springframework.cassandra.config

Class CassandraCqlClusterFactoryBean

java.lang.Object

org.springframework.cassandra.config.CassandraCqlClusterFactoryBean

All Implemented Interfaces:

DisposableBean, FactoryBean<com.datastax.driver.core.Cluster>, InitializingBean, PersistenceExceptionTranslator

Direct Known Subclasses:

CassandraClusterFactoryBean

public class CassandraCqlClusterFactoryBean
extends Object
implements FactoryBean<com.datastax.driver.core.Cluster>, InitializingBean, DisposableBean, PersistenceExceptionTranslator

Convenient factory for configuring a Cassandra Cluster.

Author:

Alex Shvid, Matthew T. Adams, David Webb

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_CONTACT_POINTS
static boolean	DEFAULT_DEFERRED_INITIALIZATION
static boolean	DEFAULT_JMX_REPORTING_ENABLED
static boolean	DEFAULT_METRICS_ENABLED
static int	DEFAULT_PORT
static boolean	DEFAULT_SSL_ENABLED
protected static org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
CassandraCqlClusterFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
protected void	executeSpecsAndScripts(List specs, List<String> scripts)
List<CreateKeyspaceSpecification>	getKeyspaceCreations()
List<DropKeyspaceSpecification>	getKeyspaceDrops()
Set<KeyspaceActionSpecification<?>>	getKeyspaceSpecifications()
com.datastax.driver.core.Cluster	getObject()
Class<? extends com.datastax.driver.core.Cluster>	getObjectType()
boolean	isSingleton()
void	setAuthProvider(com.datastax.driver.core.AuthProvider authProvider)
void	setCompressionType(CompressionType compressionType)
void	setContactPoints(String contactPoints) Sets a comma-delimited string of the contact points (hosts) to connect to.
void	setHostStateListener(com.datastax.driver.core.Host.StateListener hostStateListener)
void	setJmxReportingEnabled(boolean jmxReportingEnabled)
void	setKeyspaceCreations(List<CreateKeyspaceSpecification> specifications)
void	setKeyspaceDrops(List<DropKeyspaceSpecification> specifications)
void	setKeyspaceSpecifications(Set<KeyspaceActionSpecification<?>> keyspaceSpecifications) If accumlating is true, we append to the list, otherwise we replace the list.
void	setLatencyTracker(com.datastax.driver.core.LatencyTracker latencyTracker)
void	setLoadBalancingPolicy(com.datastax.driver.core.policies.LoadBalancingPolicy loadBalancingPolicy)
void	setMetricsEnabled(boolean metricsEnabled)
void	setPassword(String password)
void	setPoolingOptions(com.datastax.driver.core.PoolingOptions poolingOptions)
void	setPort(int port)
void	setReconnectionPolicy(com.datastax.driver.core.policies.ReconnectionPolicy reconnectionPolicy)
void	setRetryPolicy(com.datastax.driver.core.policies.RetryPolicy retryPolicy)
void	setShutdownScripts(List<String> scripts)
void	setSocketOptions(com.datastax.driver.core.SocketOptions socketOptions)
void	setSslEnabled(boolean sslEnabled)
void	setSslOptions(com.datastax.driver.core.SSLOptions sslOptions)
void	setStartupScripts(List<String> scripts)
void	setUsername(String username)
DataAccessException	translateExceptionIfPossible(RuntimeException ex)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONTACT_POINTS

public static final String DEFAULT_CONTACT_POINTS

See Also:

Constant Field Values

DEFAULT_METRICS_ENABLED

public static final boolean DEFAULT_METRICS_ENABLED

See Also:

Constant Field Values

DEFAULT_DEFERRED_INITIALIZATION

public static final boolean DEFAULT_DEFERRED_INITIALIZATION

See Also:

Constant Field Values

DEFAULT_JMX_REPORTING_ENABLED

public static final boolean DEFAULT_JMX_REPORTING_ENABLED

See Also:

Constant Field Values

DEFAULT_SSL_ENABLED

public static final boolean DEFAULT_SSL_ENABLED

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

log

protected static final org.slf4j.Logger log

Constructor Detail

CassandraCqlClusterFactoryBean

public CassandraCqlClusterFactoryBean()

Method Detail

getObject

public com.datastax.driver.core.Cluster getObject()
                                           throws Exception

Specified by:

getObject in interface FactoryBean<com.datastax.driver.core.Cluster>

Throws:

Exception

getObjectType

public Class<? extends com.datastax.driver.core.Cluster> getObjectType()

Specified by:

getObjectType in interface FactoryBean<com.datastax.driver.core.Cluster>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean<com.datastax.driver.core.Cluster>

translateExceptionIfPossible

public DataAccessException translateExceptionIfPossible(RuntimeException ex)

Specified by:

translateExceptionIfPossible in interface PersistenceExceptionTranslator

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

executeSpecsAndScripts

protected void executeSpecsAndScripts(List specs,
                          List<String> scripts)

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception

setContactPoints

public void setContactPoints(String contactPoints)

Sets a comma-delimited string of the contact points (hosts) to connect to.

setPort

public void setPort(int port)

setCompressionType

public void setCompressionType(CompressionType compressionType)

setPoolingOptions

public void setPoolingOptions(com.datastax.driver.core.PoolingOptions poolingOptions)

setSocketOptions

public void setSocketOptions(com.datastax.driver.core.SocketOptions socketOptions)

setAuthProvider

public void setAuthProvider(com.datastax.driver.core.AuthProvider authProvider)

setLoadBalancingPolicy

public void setLoadBalancingPolicy(com.datastax.driver.core.policies.LoadBalancingPolicy loadBalancingPolicy)

setReconnectionPolicy

public void setReconnectionPolicy(com.datastax.driver.core.policies.ReconnectionPolicy reconnectionPolicy)

setRetryPolicy

public void setRetryPolicy(com.datastax.driver.core.policies.RetryPolicy retryPolicy)

setMetricsEnabled

public void setMetricsEnabled(boolean metricsEnabled)

setKeyspaceCreations

public void setKeyspaceCreations(List<CreateKeyspaceSpecification> specifications)

getKeyspaceCreations

public List<CreateKeyspaceSpecification> getKeyspaceCreations()

setKeyspaceDrops

public void setKeyspaceDrops(List<DropKeyspaceSpecification> specifications)

getKeyspaceDrops

public List<DropKeyspaceSpecification> getKeyspaceDrops()

setStartupScripts

public void setStartupScripts(List<String> scripts)

setShutdownScripts

public void setShutdownScripts(List<String> scripts)

getKeyspaceSpecifications

public Set<KeyspaceActionSpecification<?>> getKeyspaceSpecifications()

Returns:

Returns the keyspaceSpecifications.

setKeyspaceSpecifications

public void setKeyspaceSpecifications(Set<KeyspaceActionSpecification<?>> keyspaceSpecifications)

If accumlating is true, we append to the list, otherwise we replace the list.

Parameters:

keyspaceSpecifications - The keyspaceSpecifications to set.

setUsername

public void setUsername(String username)

Parameters:

username - The username to set.

setPassword

public void setPassword(String password)

Parameters:

password - The password to set.

setJmxReportingEnabled

public void setJmxReportingEnabled(boolean jmxReportingEnabled)

Parameters:

jmxReportingEnabled - The jmxReportingEnabled to set.

setSslEnabled

public void setSslEnabled(boolean sslEnabled)

Parameters:

sslEnabled - The sslEnabled to set.

setSslOptions

public void setSslOptions(com.datastax.driver.core.SSLOptions sslOptions)

Parameters:

sslOptions - The sslOptions to set.

setHostStateListener

public void setHostStateListener(com.datastax.driver.core.Host.StateListener hostStateListener)

Parameters:

hostStateListener - The hostStateListener to set.

setLatencyTracker

public void setLatencyTracker(com.datastax.driver.core.LatencyTracker latencyTracker)

Parameters:

latencyTracker - The latencyTracker to set.