org.springframework.cassandra.config

Class PoolingOptionsFactoryBean

java.lang.Object

org.springframework.cassandra.config.PoolingOptionsFactoryBean

All Implemented Interfaces:

DisposableBean, FactoryBean<com.datastax.driver.core.PoolingOptions>, InitializingBean

public class PoolingOptionsFactoryBean
extends Object
implements FactoryBean<com.datastax.driver.core.PoolingOptions>, InitializingBean, DisposableBean

Pooling Options Factory Bean.

Author:

Matthew T. Adams, David Webb

Constructor Summary

Constructors

Constructor and Description
PoolingOptionsFactoryBean()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
Integer	getLocalCoreConnections()
Integer	getLocalMaxConnections()
Integer	getLocalMaxSimultaneousRequests()
Integer	getLocalMinSimultaneousRequests()
com.datastax.driver.core.PoolingOptions	getObject()
Class<?>	getObjectType()
Integer	getRemoteCoreConnections()
Integer	getRemoteMaxConnections()
Integer	getRemoteMaxSimultaneousRequests()
Integer	getRemoteMinSimultaneousRequests()
boolean	isSingleton()
void	setLocalCoreConnections(Integer localCoreConnections)
void	setLocalMaxConnections(Integer localMaxConnections)
void	setLocalMaxSimultaneousRequests(Integer localMaxSimultaneousRequests)
void	setLocalMinSimultaneousRequests(Integer localMinSimultaneousRequests)
void	setRemoteCoreConnections(Integer remoteCoreConnections)
void	setRemoteMaxConnections(Integer remoteMaxConnections)
void	setRemoteMaxSimultaneousRequests(Integer remoteMaxSimultaneousRequests)
void	setRemoteMinSimultaneousRequests(Integer remoteMinSimultaneousRequests)

Methods inherited from class java.lang.Object

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

Constructor Detail

PoolingOptionsFactoryBean

public PoolingOptionsFactoryBean()

Method Detail

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

getObject

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

Specified by:

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

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

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

isSingleton

public boolean isSingleton()

Specified by:

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

getLocalMinSimultaneousRequests

public Integer getLocalMinSimultaneousRequests()

Returns:

Returns the localMinSimultaneousRequests.

setLocalMinSimultaneousRequests

public void setLocalMinSimultaneousRequests(Integer localMinSimultaneousRequests)

Parameters:

localMinSimultaneousRequests - The localMinSimultaneousRequests to set.

getLocalMaxSimultaneousRequests

public Integer getLocalMaxSimultaneousRequests()

Returns:

Returns the localMaxSimultaneousRequests.

setLocalMaxSimultaneousRequests

public void setLocalMaxSimultaneousRequests(Integer localMaxSimultaneousRequests)

Parameters:

localMaxSimultaneousRequests - The localMaxSimultaneousRequests to set.

getLocalCoreConnections

public Integer getLocalCoreConnections()

Returns:

Returns the localCoreConnections.

setLocalCoreConnections

public void setLocalCoreConnections(Integer localCoreConnections)

Parameters:

localCoreConnections - The localCoreConnections to set.

getLocalMaxConnections

public Integer getLocalMaxConnections()

Returns:

Returns the localMaxConnections.

setLocalMaxConnections

public void setLocalMaxConnections(Integer localMaxConnections)

Parameters:

localMaxConnections - The localMaxConnections to set.

getRemoteMinSimultaneousRequests

public Integer getRemoteMinSimultaneousRequests()

Returns:

Returns the remoteMinSimultaneousRequests.

setRemoteMinSimultaneousRequests

public void setRemoteMinSimultaneousRequests(Integer remoteMinSimultaneousRequests)

Parameters:

remoteMinSimultaneousRequests - The remoteMinSimultaneousRequests to set.

getRemoteMaxSimultaneousRequests

public Integer getRemoteMaxSimultaneousRequests()

Returns:

Returns the remoteMaxSimultaneousRequests.

setRemoteMaxSimultaneousRequests

public void setRemoteMaxSimultaneousRequests(Integer remoteMaxSimultaneousRequests)

Parameters:

remoteMaxSimultaneousRequests - The remoteMaxSimultaneousRequests to set.

getRemoteCoreConnections

public Integer getRemoteCoreConnections()

Returns:

Returns the remoteCoreConnections.

setRemoteCoreConnections

public void setRemoteCoreConnections(Integer remoteCoreConnections)

Parameters:

remoteCoreConnections - The remoteCoreConnections to set.

getRemoteMaxConnections

public Integer getRemoteMaxConnections()

Returns:

Returns the remoteMaxConnections.

setRemoteMaxConnections

public void setRemoteMaxConnections(Integer remoteMaxConnections)

Parameters:

remoteMaxConnections - The remoteMaxConnections to set.