org.ikasan.component.endpoint.mongo

Class MongoClientConfiguration

java.lang.Object

org.ikasan.component.endpoint.mongo.MongoClientConfiguration

public class MongoClientConfiguration
extends java.lang.Object

Mongo configuration options passed at runtime. For full details see Mongo Client Driver http://api.mongodb.org/java/2.12/

Author:

Ikasan Development Team

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Boolean	alwaysUseMBeans Sets whether JMX beans registered by the driver should always be MBeans, regardless of whether the VM is Java 6 or greater - overrides default driver options if specified
protected java.lang.Boolean	authenticated do we authenticate the connection
protected java.util.Map<java.lang.String,java.lang.String>	collectionNames collection key name and actual name
protected java.lang.Integer	connectionsPerHost Sets the maximum number of connections per host - overrides default driver options if specified
protected java.lang.Integer	connectionTimeout Sets the connection timeout - overrides default driver options if specified
protected java.util.List<java.lang.String>	connectionUrls Mongo Driver Properties
protected java.lang.Boolean	cursorFinalizerEnabled Sets whether cursor finalizers are enabled.
protected java.lang.String	databaseName database name
protected java.lang.String	description Sets the description - overrides default driver options if specified
protected java.lang.Integer	heartbeatConnectTimeout Sets the heartbeat connect timeout - overrides default driver options if specified
protected java.lang.Integer	heartbeatFrequency Sets the heartbeat frequency - overrides default driver options if specified
protected java.lang.Integer	heartbeatSocketTimeout Sets the heartbeat connect socket timeout - overrides default driver options if specified
protected java.lang.Boolean	legacyDefaults Sets defaults to be what they are in MongoOptions - overrides default driver options if specified
protected java.lang.Integer	localThreshold Sets the localThreshold - overrides default driver options if specified
protected java.lang.Integer	maxConnectionIdleTime Sets the maximum idle time for a pooled connection - overrides default driver options if specified
protected java.lang.Integer	maxConnectionLifeTime Sets the maximum life time for a pooled connection - overrides default driver options if specified
protected java.lang.Integer	maxWaitTime Sets the maximum time that a thread will block waiting for a connection - overrides default driver options if specified
protected java.lang.Integer	minConnectionsPerHost Sets the minimum number of connections per host - overrides default driver options if specified
protected java.lang.Integer	minHeartbeatFrequency Sets the min heart beat frequency - overrides default driver options if specified
protected java.lang.String	password authentication credential
protected com.mongodb.ReadPreference	readPreference represents preferred replica set members to which a query or command can be sent
protected java.lang.String	requiredReplicaSetName Sets the required replica set name for the cluster - overrides default driver options if specified
protected java.lang.Boolean	socketKeepAlive Sets whether socket keep alive is enabled - overrides default driver options if specified
protected java.lang.Integer	socketTimeout Sets the socket timeout - overrides default driver options if specified
protected java.lang.Integer	threadsAllowedToBlockForConnectionMultiplier Sets the multiplier for number of threads allowed to block waiting for a connection - overrides default driver options if specified
protected java.lang.String	username authentication principal
protected com.mongodb.WriteConcern	writeConcern Controls the acknowledgment of write operations

Constructor Summary

Constructors

Constructor and Description
MongoClientConfiguration()

Method Summary

Modifier and Type	Method and Description
java.lang.Boolean	getAlwaysUseMBeans()
java.lang.Boolean	getAuthenticated()
java.util.Map<java.lang.String,java.lang.String>	getCollectionNames()
java.lang.Integer	getConnectionsPerHost()
java.lang.Integer	getConnectionTimeout()
java.util.List<java.lang.String>	getConnectionUrls()
java.lang.Boolean	getCursorFinalizerEnabled()
java.lang.String	getDatabaseName()
java.lang.String	getDescription()
java.lang.Integer	getHeartbeatConnectTimeout()
java.lang.Integer	getHeartbeatFrequency()
java.lang.Integer	getHeartbeatSocketTimeout()
java.lang.Boolean	getLegacyDefaults()
java.lang.Integer	getLocalThreshold()
java.lang.Integer	getMaxConnectionIdleTime()
java.lang.Integer	getMaxConnectionLifeTime()
java.lang.Integer	getMaxWaitTime()
java.lang.Integer	getMinConnectionsPerHost()
java.lang.Integer	getMinHeartbeatFrequency()
java.lang.String	getPassword()
com.mongodb.ReadPreference	getReadPreference()
java.lang.String	getRequiredReplicaSetName()
protected java.util.List<com.mongodb.ServerAddress>	getServerAddresses() Utility method for translating the list of connectionUrls (host:port) to host and port into ServerAddress(es)
java.lang.Boolean	getSocketKeepAlive()
java.lang.Integer	getSocketTimeout()
java.lang.Integer	getThreadsAllowedToBlockForConnectionMultiplier()
java.lang.String	getUsername()
com.mongodb.WriteConcern	getWriteConcern()
java.lang.Boolean	isAuthenticated()
void	setAlwaysUseMBeans(java.lang.Boolean alwaysUseMBeans)
void	setAuthenticated(java.lang.Boolean authenticated)
void	setCollectionNames(java.util.Map<java.lang.String,java.lang.String> collectionNames)
void	setConnectionsPerHost(java.lang.Integer connectionsPerHost)
void	setConnectionTimeout(java.lang.Integer connectionTimeout)
void	setConnectionUrls(java.util.List<java.lang.String> connectionUrls)
void	setCursorFinalizerEnabled(java.lang.Boolean cursorFinalizerEnabled)
void	setDatabaseName(java.lang.String databaseName)
void	setDescription(java.lang.String description)
void	setHeartbeatConnectTimeout(java.lang.Integer heartbeatConnectTimeout)
void	setHeartbeatFrequency(java.lang.Integer heartbeatFrequency)
void	setHeartbeatSocketTimeout(java.lang.Integer heartbeatSocketTimeout)
void	setLegacyDefaults(java.lang.Boolean legacyDefaults)
void	setLocalThreshold(java.lang.Integer localThreshold)
void	setMaxConnectionIdleTime(java.lang.Integer maxConnectionIdleTime)
void	setMaxConnectionLifeTime(java.lang.Integer maxConnectionLifeTime)
void	setMaxWaitTime(java.lang.Integer maxWaitTime)
void	setMinConnectionsPerHost(java.lang.Integer minConnectionsPerHost)
void	setMinHeartbeatFrequency(java.lang.Integer minHeartbeatFrequency)
void	setPassword(java.lang.String password)
void	setReadPreference(com.mongodb.ReadPreference readPreference)
void	setRequiredReplicaSetName(java.lang.String requiredReplicaSetName)
void	setSocketKeepAlive(java.lang.Boolean socketKeepAlive)
void	setSocketTimeout(java.lang.Integer socketTimeout)
void	setThreadsAllowedToBlockForConnectionMultiplier(java.lang.Integer threadsAllowedToBlockForConnectionMultiplier)
void	setUsername(java.lang.String username)
void	setWriteConcern(com.mongodb.WriteConcern writeConcern)
java.lang.String	toString()
void	validate() Basic validation of the configuration.

Methods inherited from class java.lang.Object

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

Field Detail

connectionUrls

protected java.util.List<java.lang.String> connectionUrls

Mongo Driver Properties

authenticated

protected java.lang.Boolean authenticated

do we authenticate the connection

username

protected java.lang.String username

authentication principal

password

protected java.lang.String password

authentication credential

databaseName

protected java.lang.String databaseName

database name

collectionNames

protected java.util.Map<java.lang.String,java.lang.String> collectionNames

collection key name and actual name

readPreference

protected com.mongodb.ReadPreference readPreference

represents preferred replica set members to which a query or command can be sent

writeConcern

protected com.mongodb.WriteConcern writeConcern

Controls the acknowledgment of write operations

localThreshold

protected java.lang.Integer localThreshold

Sets the localThreshold - overrides default driver options if specified

alwaysUseMBeans

protected java.lang.Boolean alwaysUseMBeans

Sets whether JMX beans registered by the driver should always be MBeans, regardless of whether the VM is Java 6 or greater - overrides default driver options if specified

connectionsPerHost

protected java.lang.Integer connectionsPerHost

Sets the maximum number of connections per host - overrides default driver options if specified

connectionTimeout

protected java.lang.Integer connectionTimeout

Sets the connection timeout - overrides default driver options if specified

cursorFinalizerEnabled

protected java.lang.Boolean cursorFinalizerEnabled

Sets whether cursor finalizers are enabled. - overrides default driver options if specified

description

protected java.lang.String description

Sets the description - overrides default driver options if specified

minHeartbeatFrequency

protected java.lang.Integer minHeartbeatFrequency

Sets the min heart beat frequency - overrides default driver options if specified

heartbeatConnectTimeout

protected java.lang.Integer heartbeatConnectTimeout

Sets the heartbeat connect timeout - overrides default driver options if specified

heartbeatFrequency

protected java.lang.Integer heartbeatFrequency

Sets the heartbeat frequency - overrides default driver options if specified

heartbeatSocketTimeout

protected java.lang.Integer heartbeatSocketTimeout

Sets the heartbeat connect socket timeout - overrides default driver options if specified

legacyDefaults

protected java.lang.Boolean legacyDefaults

Sets defaults to be what they are in MongoOptions - overrides default driver options if specified

maxConnectionIdleTime

protected java.lang.Integer maxConnectionIdleTime

Sets the maximum idle time for a pooled connection - overrides default driver options if specified

maxConnectionLifeTime

protected java.lang.Integer maxConnectionLifeTime

Sets the maximum life time for a pooled connection - overrides default driver options if specified

maxWaitTime

protected java.lang.Integer maxWaitTime

Sets the maximum time that a thread will block waiting for a connection - overrides default driver options if specified

minConnectionsPerHost

protected java.lang.Integer minConnectionsPerHost

Sets the minimum number of connections per host - overrides default driver options if specified

requiredReplicaSetName

protected java.lang.String requiredReplicaSetName

Sets the required replica set name for the cluster - overrides default driver options if specified

socketKeepAlive

protected java.lang.Boolean socketKeepAlive

Sets whether socket keep alive is enabled - overrides default driver options if specified

socketTimeout

protected java.lang.Integer socketTimeout

Sets the socket timeout - overrides default driver options if specified

threadsAllowedToBlockForConnectionMultiplier

protected java.lang.Integer threadsAllowedToBlockForConnectionMultiplier

Sets the multiplier for number of threads allowed to block waiting for a connection - overrides default driver options if specified

Constructor Detail

MongoClientConfiguration

public MongoClientConfiguration()

Method Detail

getConnectionUrls

public java.util.List<java.lang.String> getConnectionUrls()

setConnectionUrls

public void setConnectionUrls(java.util.List<java.lang.String> connectionUrls)

isAuthenticated

public java.lang.Boolean isAuthenticated()

getAuthenticated

public java.lang.Boolean getAuthenticated()

setAuthenticated

public void setAuthenticated(java.lang.Boolean authenticated)

getUsername

public java.lang.String getUsername()

setUsername

public void setUsername(java.lang.String username)

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String password)

getDatabaseName

public java.lang.String getDatabaseName()

setDatabaseName

public void setDatabaseName(java.lang.String databaseName)

getCollectionNames

public java.util.Map<java.lang.String,java.lang.String> getCollectionNames()

setCollectionNames

public void setCollectionNames(java.util.Map<java.lang.String,java.lang.String> collectionNames)

getReadPreference

public com.mongodb.ReadPreference getReadPreference()

setReadPreference

public void setReadPreference(com.mongodb.ReadPreference readPreference)

getWriteConcern

public com.mongodb.WriteConcern getWriteConcern()

setWriteConcern

public void setWriteConcern(com.mongodb.WriteConcern writeConcern)

getLocalThreshold

public java.lang.Integer getLocalThreshold()

setLocalThreshold

public void setLocalThreshold(java.lang.Integer localThreshold)

getAlwaysUseMBeans

public java.lang.Boolean getAlwaysUseMBeans()

setAlwaysUseMBeans

public void setAlwaysUseMBeans(java.lang.Boolean alwaysUseMBeans)

getConnectionsPerHost

public java.lang.Integer getConnectionsPerHost()

setConnectionsPerHost

public void setConnectionsPerHost(java.lang.Integer connectionsPerHost)

getConnectionTimeout

public java.lang.Integer getConnectionTimeout()

setConnectionTimeout

public void setConnectionTimeout(java.lang.Integer connectionTimeout)

getCursorFinalizerEnabled

public java.lang.Boolean getCursorFinalizerEnabled()

setCursorFinalizerEnabled

public void setCursorFinalizerEnabled(java.lang.Boolean cursorFinalizerEnabled)

getDescription

public java.lang.String getDescription()

setDescription

public void setDescription(java.lang.String description)

getMinHeartbeatFrequency

public java.lang.Integer getMinHeartbeatFrequency()

setMinHeartbeatFrequency

public void setMinHeartbeatFrequency(java.lang.Integer minHeartbeatFrequency)

getHeartbeatConnectTimeout

public java.lang.Integer getHeartbeatConnectTimeout()

setHeartbeatConnectTimeout

public void setHeartbeatConnectTimeout(java.lang.Integer heartbeatConnectTimeout)

getHeartbeatFrequency

public java.lang.Integer getHeartbeatFrequency()

setHeartbeatFrequency

public void setHeartbeatFrequency(java.lang.Integer heartbeatFrequency)

getHeartbeatSocketTimeout

public java.lang.Integer getHeartbeatSocketTimeout()

setHeartbeatSocketTimeout

public void setHeartbeatSocketTimeout(java.lang.Integer heartbeatSocketTimeout)

getLegacyDefaults

public java.lang.Boolean getLegacyDefaults()

setLegacyDefaults

public void setLegacyDefaults(java.lang.Boolean legacyDefaults)

getMaxConnectionIdleTime

public java.lang.Integer getMaxConnectionIdleTime()

setMaxConnectionIdleTime

public void setMaxConnectionIdleTime(java.lang.Integer maxConnectionIdleTime)

getMaxConnectionLifeTime

public java.lang.Integer getMaxConnectionLifeTime()

setMaxConnectionLifeTime

public void setMaxConnectionLifeTime(java.lang.Integer maxConnectionLifeTime)

getMaxWaitTime

public java.lang.Integer getMaxWaitTime()

setMaxWaitTime

public void setMaxWaitTime(java.lang.Integer maxWaitTime)

getMinConnectionsPerHost

public java.lang.Integer getMinConnectionsPerHost()

setMinConnectionsPerHost

public void setMinConnectionsPerHost(java.lang.Integer minConnectionsPerHost)

getRequiredReplicaSetName

public java.lang.String getRequiredReplicaSetName()

setRequiredReplicaSetName

public void setRequiredReplicaSetName(java.lang.String requiredReplicaSetName)

getSocketKeepAlive

public java.lang.Boolean getSocketKeepAlive()

setSocketKeepAlive

public void setSocketKeepAlive(java.lang.Boolean socketKeepAlive)

getSocketTimeout

public java.lang.Integer getSocketTimeout()

setSocketTimeout

public void setSocketTimeout(java.lang.Integer socketTimeout)

getThreadsAllowedToBlockForConnectionMultiplier

public java.lang.Integer getThreadsAllowedToBlockForConnectionMultiplier()

setThreadsAllowedToBlockForConnectionMultiplier

public void setThreadsAllowedToBlockForConnectionMultiplier(java.lang.Integer threadsAllowedToBlockForConnectionMultiplier)

getServerAddresses

protected java.util.List<com.mongodb.ServerAddress> getServerAddresses()

Utility method for translating the list of connectionUrls (host:port) to host and port into ServerAddress(es)

Returns:

validate

public void validate()

Basic validation of the configuration.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object