com.allanbank.mongodb.connection.auth

Class AuthenticationConnectionFactory

java.lang.Object

com.allanbank.mongodb.connection.auth.AuthenticationConnectionFactory

All Implemented Interfaces:

ConnectionFactory, ProxiedConnectionFactory, Closeable, AutoCloseable

public class AuthenticationConnectionFactory
extends Object
implements ProxiedConnectionFactory

AuthenticationConnectionFactory wraps all of the connections with AuthenticatingConnections.

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 ©:

2012, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
AuthenticatingConnection	connect() Creates a connection to the address provided.
AuthenticatingConnection	connect(ServerState server, MongoClientConfiguration config) Creates a connection to the address provided.
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

Constructor Detail

AuthenticationConnectionFactory

public AuthenticationConnectionFactory(ProxiedConnectionFactory factory,
                               MongoClientConfiguration config)

Creates a new AuthenticationConnectionFactory.

Parameters:

factory - The factory to wrap connections wit AuthenticatingConnection.

config - The default config.

Method Detail

close

public void close()

Overridden to close the proxied ConnectionFactory.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

connect

public AuthenticatingConnection connect()
                                 throws IOException

Creates a connection to the address provided.

Overridden to return a connection then ensures the connection is properly authenticated before reconnecting.

Specified by:

connect in interface ConnectionFactory

Returns:

The Connection to MongoDB.

Throws:

IOException - On a failure connecting to the server.

connect

public AuthenticatingConnection connect(ServerState server,
                               MongoClientConfiguration config)
                                 throws IOException

Creates a connection to the address provided.

Overridden to wrap the returned connection with an AuthenticatingConnection.

Specified by:

connect in interface ProxiedConnectionFactory

Parameters:

server - The MongoDB server to connect to.

config - The configuration for the Connection to the MongoDB server.

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 proxied 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 but replace his connection factory with our own.

Specified by:

getReconnectStrategy in interface ConnectionFactory

Returns:

The reconnection strategy for the type of connections.