public class CassandraCqlClusterFactoryBean extends Object implements FactoryBean<com.datastax.driver.core.Cluster>, InitializingBean, DisposableBean, PersistenceExceptionTranslator
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 and Description |
---|
CassandraCqlClusterFactoryBean() |
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) |
public static final String DEFAULT_CONTACT_POINTS
public static final boolean DEFAULT_METRICS_ENABLED
public static final boolean DEFAULT_DEFERRED_INITIALIZATION
public static final boolean DEFAULT_JMX_REPORTING_ENABLED
public static final boolean DEFAULT_SSL_ENABLED
public static final int DEFAULT_PORT
protected static final org.slf4j.Logger log
public com.datastax.driver.core.Cluster getObject() throws Exception
getObject
in interface FactoryBean<com.datastax.driver.core.Cluster>
Exception
public Class<? extends com.datastax.driver.core.Cluster> getObjectType()
getObjectType
in interface FactoryBean<com.datastax.driver.core.Cluster>
public boolean isSingleton()
isSingleton
in interface FactoryBean<com.datastax.driver.core.Cluster>
public DataAccessException translateExceptionIfPossible(RuntimeException ex)
translateExceptionIfPossible
in interface PersistenceExceptionTranslator
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface InitializingBean
Exception
public void destroy() throws Exception
destroy
in interface DisposableBean
Exception
public void setContactPoints(String contactPoints)
public void setPort(int port)
public void setCompressionType(CompressionType compressionType)
public void setPoolingOptions(com.datastax.driver.core.PoolingOptions poolingOptions)
public void setSocketOptions(com.datastax.driver.core.SocketOptions socketOptions)
public void setAuthProvider(com.datastax.driver.core.AuthProvider authProvider)
public void setLoadBalancingPolicy(com.datastax.driver.core.policies.LoadBalancingPolicy loadBalancingPolicy)
public void setReconnectionPolicy(com.datastax.driver.core.policies.ReconnectionPolicy reconnectionPolicy)
public void setRetryPolicy(com.datastax.driver.core.policies.RetryPolicy retryPolicy)
public void setMetricsEnabled(boolean metricsEnabled)
public void setKeyspaceCreations(List<CreateKeyspaceSpecification> specifications)
public List<CreateKeyspaceSpecification> getKeyspaceCreations()
public void setKeyspaceDrops(List<DropKeyspaceSpecification> specifications)
public List<DropKeyspaceSpecification> getKeyspaceDrops()
public Set<KeyspaceActionSpecification<?>> getKeyspaceSpecifications()
public void setKeyspaceSpecifications(Set<KeyspaceActionSpecification<?>> keyspaceSpecifications)
keyspaceSpecifications
- The keyspaceSpecifications to set.public void setUsername(String username)
username
- The username to set.public void setPassword(String password)
password
- The password to set.public void setJmxReportingEnabled(boolean jmxReportingEnabled)
jmxReportingEnabled
- The jmxReportingEnabled to set.public void setSslEnabled(boolean sslEnabled)
sslEnabled
- The sslEnabled to set.public void setSslOptions(com.datastax.driver.core.SSLOptions sslOptions)
sslOptions
- The sslOptions to set.public void setHostStateListener(com.datastax.driver.core.Host.StateListener hostStateListener)
hostStateListener
- The hostStateListener to set.public void setLatencyTracker(com.datastax.driver.core.LatencyTracker latencyTracker)
latencyTracker
- The latencyTracker to set.Copyright © 2011-2014–2015 Pivotal Software, Inc.. All rights reserved.