com.allanbank.mongodb.client.connection.rs

Class ReplicaSetConnectionFactory

java.lang.Object

com.allanbank.mongodb.client.connection.rs.ReplicaSetConnectionFactory

All Implemented Interfaces:

ConnectionFactory, Closeable, AutoCloseable

public class ReplicaSetConnectionFactory
extends Object
implements ConnectionFactory

Provides the ability to create connections to a replica-set environment.

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	bootstrap() Finds the primary member of the replica set.
void	close()
Connection	connect() Creates a new connection to the replica set.
protected Cluster	getCluster() Returns the clusterState value.
ClusterStats	getClusterStats() Returns the meta-data on the current cluster.
ClusterType	getClusterType() Returns the type of cluster the connection factory connects to.
ReconnectStrategy	getReconnectStrategy() Returns the reconnection strategy for the type of connections.
protected boolean	isWritable(Server server, Connection connection) Determines if the connection is to the primary member of the cluster.
protected List<Server>	locatePrimary() Locates the primary server in the cluster.

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

myConnectionFactory

protected final ProxiedConnectionFactory myConnectionFactory

The factory to create proxied connections.

Constructor Detail

ReplicaSetConnectionFactory

public ReplicaSetConnectionFactory(ProxiedConnectionFactory factory,
                           MongoClientConfiguration config)

Creates a new ReplicaSetConnectionFactory.

Parameters:

factory - The factory to create proxied connections.

config - The MongoDB client configuration.

Method Detail

bootstrap

public void bootstrap()

Finds the primary member of the replica set.

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 replica set.

Specified by:

connect in interface ConnectionFactory

Returns:

The Connection to MongoDB.

Throws:

IOException - On a failure connecting to the server.

See Also:

ConnectionFactory.connect()

getClusterStats

public ClusterStats getClusterStats()

Returns the meta-data on the current cluster.

Overridden to return the Cluster.

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 ClusterType.REPLICA_SET 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 a replica set ReconnectStrategy.

Specified by:

getReconnectStrategy in interface ConnectionFactory

Returns:

The reconnection strategy for the type of connections.

getCluster

protected Cluster getCluster()

Returns the clusterState value.

Returns:

The clusterState value.

isWritable

protected boolean isWritable(Server server,
                 Connection connection)

Determines if the connection is to the primary member of the cluster.

Parameters:

server - The server connected to.

connection - The connection to test.

Returns:

True if the connection is to the primary member of the cluster/replica set.

locatePrimary

protected List<Server> locatePrimary()

Locates the primary server in the cluster.

Returns:

The list of primary servers.