com.allanbank.mongodb.connection.sharded

Class ShardedConnectionFactory

java.lang.Object

com.allanbank.mongodb.connection.sharded.ShardedConnectionFactory

All Implemented Interfaces:

ConnectionFactory, Closeable, AutoCloseable

public class ShardedConnectionFactory
extends Object
implements ConnectionFactory

Provides the ability to create connections to a shard configuration via mongos servers.

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 ShardedConnectionFactory.
protected ProxiedConnectionFactory	myConnectionFactory The factory to create proxied connections.

Constructor Summary

Constructors

Constructor and Description
ShardedConnectionFactory(ProxiedConnectionFactory factory, MongoClientConfiguration config) Creates a new ShardedConnectionFactory.

Method Summary

Methods

Modifier and Type	Method and Description
void	bootstrap() Finds the mongos servers.
void	close()
Connection	connect() Creates a new connection to the shared mongos servers.
protected ClusterState	getClusterState() Returns the clusterState value.
ClusterType	getClusterType() Returns the type of cluster the connection factory connects to.
ReconnectStrategy	getReconnectStrategy() Returns the reconnection strategy for the type of connections.

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 ShardedConnectionFactory.

myConnectionFactory

protected final ProxiedConnectionFactory myConnectionFactory

The factory to create proxied connections.

Constructor Detail

ShardedConnectionFactory

public ShardedConnectionFactory(ProxiedConnectionFactory factory,
                        MongoClientConfiguration config)

Creates a new ShardedConnectionFactory.

Parameters:

factory - The factory to create proxied connections.

config - The initial configuration.

Method Detail

bootstrap

public void bootstrap()

Finds the mongos servers.

Performs a find on the config database's mongos collection to return the id for all of the mongos servers in the cluster.

A single mongos entry looks like:

 
 { 
     "_id" : "mongos.example.com:27017", 
     "ping" : ISODate("2011-12-05T23:54:03.122Z"), 
     "up" : 330 
 }
 
 

close

public void close()

Overridden to close the cluster state and the ProxiedConnectionFactory.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

connect

public Connection connect()
                   throws IOException

Creates a new connection to the shared mongos servers.

Specified by:

connect in interface ConnectionFactory

Returns:

The Connection to MongoDB.

Throws:

IOException - On a failure connecting to the server.

See Also:

ConnectionFactory.connect()

getClusterType

public ClusterType getClusterType()

Returns the type of cluster the connection factory connects to.

Overridden to return ClusterType.SHARDED cluster type.

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 but replace his state and selector with our own.

Specified by:

getReconnectStrategy in interface ConnectionFactory

Returns:

The reconnection strategy for the type of connections.

getClusterState

protected ClusterState getClusterState()

Returns the clusterState value.

Returns:

The clusterState value.