com.allanbank.mongodb.connection.rs

Class ReplicaSetConnectionFactory

java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	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 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 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()

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.

getClusterState

protected ClusterState getClusterState()

Returns the clusterState value.

Returns:

The clusterState value.