org.openspaces.persistency.cassandra
Class CassandraSpaceDataSourceFactoryBean

java.lang.Object
  org.openspaces.persistency.cassandra.CassandraSpaceDataSourceFactoryBean

All Implemented Interfaces:

DisposableBean, FactoryBean<CassandraSpaceDataSource>, InitializingBean

public class CassandraSpaceDataSourceFactoryBean
extends Object
implements FactoryBean<CassandraSpaceDataSource>, InitializingBean, DisposableBean

A FactoryBean for creating a singleton instance of CassandraSpaceDataSource.

Since:

9.1.1

Author:

Dan Kilman

Constructor Summary

CassandraSpaceDataSourceFactoryBean()

Method Summary

void	afterPropertiesSet()
void	destroy()
protected CassandraSpaceDataSourceConfigurer	getConfigurer()
CassandraSpaceDataSource	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setBatchLimit(int batchLimit)
void	setCassandraDataSource(CassandraDataSource cassandraDataSource)
void	setDynamicPropertyValueSerializer(PropertyValueSerializer dynamicPropertyValueSerializer)
void	setFixedPropertyValueSerializer(PropertyValueSerializer fixedPropertyValueSerializer)
void	setHectorClient(HectorCassandraClient hectorClient)
void	setMaximumNumberOfConnections(int maximumNumberOfConnections)
void	setMinimumNumberOfConnections(int minimumNumberOfConnections)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraSpaceDataSourceFactoryBean

public CassandraSpaceDataSourceFactoryBean()

Method Detail

getConfigurer

protected CassandraSpaceDataSourceConfigurer getConfigurer()

setFixedPropertyValueSerializer

public void setFixedPropertyValueSerializer(PropertyValueSerializer fixedPropertyValueSerializer)

See Also:

CassandraSpaceDataSourceConfigurer.fixedPropertyValueSerializer(PropertyValueSerializer)

setDynamicPropertyValueSerializer

public void setDynamicPropertyValueSerializer(PropertyValueSerializer dynamicPropertyValueSerializer)

See Also:

CassandraSpaceDataSourceConfigurer.dynamicPropertyValueSerializer(PropertyValueSerializer)

setCassandraDataSource

public void setCassandraDataSource(CassandraDataSource cassandraDataSource)

See Also:

CassandraSpaceDataSourceConfigurer.cassandraDataSource(CassandraDataSource)

setHectorClient

public void setHectorClient(HectorCassandraClient hectorClient)

See Also:

CassandraSpaceDataSourceConfigurer.cassandraDataSource(CassandraDataSource)

setMinimumNumberOfConnections

public void setMinimumNumberOfConnections(int minimumNumberOfConnections)

See Also:

CassandraSpaceDataSourceConfigurer.minimumNumberOfConnections(int)

setMaximumNumberOfConnections

public void setMaximumNumberOfConnections(int maximumNumberOfConnections)

See Also:

CassandraSpaceDataSourceConfigurer.maximumNumberOfConnections(int)

setBatchLimit

public void setBatchLimit(int batchLimit)

See Also:

CassandraSpaceDataSourceConfigurer.batchLimit(int)

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

getObject

public CassandraSpaceDataSource getObject()
                                   throws Exception

Specified by:

getObject in interface FactoryBean<CassandraSpaceDataSource>

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<CassandraSpaceDataSource>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean<CassandraSpaceDataSource>

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception