com.allanbank.mongodb.client.connection.bootstrap

Class BootstrapConnectionFactory

java.lang.Object

com.allanbank.mongodb.client.connection.bootstrap.BootstrapConnectionFactory

All Implemented Interfaces:

ConnectionFactory, Closeable, AutoCloseable

public class BootstrapConnectionFactory
extends Object
implements ConnectionFactory

Provides the ability to bootstrap into the appropriate ConnectionFactory based on the configuration of the server(s) connected to.

API Warning:

This class is NOT part of the drivers API. This class may be mutated in incompatible ways between any two releases of the driver.

Copyright ©:

2011-2014, Allanbank Consulting, Inc., All Rights Reserved

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	LOG The logger for the BootstrapConnectionFactory.

Constructor Summary

Constructors

Constructor and Description
BootstrapConnectionFactory(MongoClientConfiguration config) Creates a BootstrapConnectionFactory

Method Summary

Methods

Modifier and Type	Method and Description
protected void	bootstrap() Re-bootstraps the environment.
protected ConnectionFactory	bootstrapReplicaSet(ProxiedConnectionFactory factory) Initializes the factory for connecting to the replica set.
protected ConnectionFactory	bootstrapSharded(ProxiedConnectionFactory factory) Initializes the factory for connecting to the sharded cluster.
void	close()
Connection	connect() Creates a connection to the address provided.
ClusterStats	getClusterStats() Returns the meta-data on the current cluster.
ClusterType	getClusterType() Returns the type of cluster the connection factory connects to.
protected MongoClientConfiguration	getConfig() The configuration for the client.
protected ConnectionFactory	getDelegate() Returns the underlying delegate factory.
ReconnectStrategy	getReconnectStrategy() Returns the reconnection strategy for the type of connections.
protected void	setDelegate(ConnectionFactory delegate) Sets the underlying delegate factory.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Log LOG

The logger for the BootstrapConnectionFactory.

Constructor Detail

BootstrapConnectionFactory

public BootstrapConnectionFactory(MongoClientConfiguration config)

Creates a BootstrapConnectionFactory

Parameters:

config - The configuration to use in discovering the server configuration.

Method Detail

close

public void close()

Overridden to close the delegate ConnectionFactory.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

connect

public Connection connect()
                   throws IOException

Creates a connection to the address provided.

Delegates the connection to the setup delegate.

Specified by:

connect in interface ConnectionFactory

Returns:

The Connection to MongoDB.

Throws:

IOException - On a failure connecting to the server.

getClusterStats

public ClusterStats getClusterStats()

Returns the meta-data on the current cluster.

Overridden to return the cluster stats of the proxied ConnectionFactory.

Specified by:

getClusterStats in interface ConnectionFactory

Returns:

The meta-data on the current cluster.

getClusterType

public ClusterType getClusterType()

Returns the type of cluster the connection factory connects to.

Overridden to return the cluster type of the delegate ConnectionFactory.

Specified by:

getClusterType in interface ConnectionFactory

Returns:

The type of cluster the connection factory connects to.

getReconnectStrategy

public ReconnectStrategy getReconnectStrategy()

Returns the reconnection strategy for the type of connections.

Overridden to return the delegates strategy.

Specified by:

getReconnectStrategy in interface ConnectionFactory

Returns:

The reconnection strategy for the type of connections.

bootstrap

protected void bootstrap()

Re-bootstraps the environment. Normally this method is only called once during the constructor of the factory to initialize the delegate but users can reset the delegate by manually invoking this method.

A bootstrap will issue one commands to the first working MongoDB process. The reply to the IsMaster command is used to detect connecting to a mongos process and by extension a Sharded configuration.

If not using a Sharded configuration then the server status is checked for a repl element. If present a Replication Set configuration is assumed.

If neither a Sharded or Replication Set is being used then a plain socket connection factory is used.

bootstrapReplicaSet

protected ConnectionFactory bootstrapReplicaSet(ProxiedConnectionFactory factory)

Initializes the factory for connecting to the replica set.

Parameters:

factory - The factory for connecting to the servers directly.

Returns:

The connection factory for connecting to the replica set.

bootstrapSharded

protected ConnectionFactory bootstrapSharded(ProxiedConnectionFactory factory)

Initializes the factory for connecting to the sharded cluster.

Parameters:

factory - The factory for connecting to the servers directly.

Returns:

The connection factory for connecting to the sharded cluster.

getConfig

protected MongoClientConfiguration getConfig()

The configuration for the client.

Returns:

The configuration for the client.

getDelegate

protected ConnectionFactory getDelegate()

Returns the underlying delegate factory.

Returns:

The underlying delegate factory.

setDelegate

protected void setDelegate(ConnectionFactory delegate)

Sets the underlying delegate factory.

Parameters:

delegate - The underlying delegate factory.