com.allanbank.mongodb.connection.bootstrap

Class BootstrapConnectionFactory

java.lang.Object

com.allanbank.mongodb.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-2012, Allanbank Consulting, Inc., All Rights Reserved

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	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
void	bootstrap() Re-bootstraps the environment.
void	close()
Connection	connect() Creates a connection to the address provided.
ClusterType	getClusterType() Returns the type of cluster the connection factory connects to.
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 Logger 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

bootstrap

public 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 ServerStatus 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.

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.

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.

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.