com.allanbank.mongodb.client.connection.socket

Class SocketConnectionFactory

java.lang.Object

com.allanbank.mongodb.client.connection.socket.SocketConnectionFactory

All Implemented Interfaces:

ConnectionFactory, ProxiedConnectionFactory, Closeable, AutoCloseable

public class SocketConnectionFactory
extends Object
implements ProxiedConnectionFactory

ConnectionFactory to create direct socket connections to the 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-2014, Allanbank Consulting, Inc., All Rights Reserved

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	SocketConnectionFactory.ConfigurationListener ConfigurationListener provides a listener for changes in the client's configuration.

Constructor Summary

Constructors

Constructor and Description
SocketConnectionFactory(MongoClientConfiguration config) Creates a new SocketConnectionFactory.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected void	configurationChanged(PropertyChangeEvent evt) Notification of a change to the configuration of the client.
Connection	connect() Creates a connection to the address provided.
Connection	connect(Server server, MongoClientConfiguration config) Creates a connection to the address provided.
Cluster	getCluster() Returns the cluster state.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SocketConnectionFactory

public SocketConnectionFactory(MongoClientConfiguration config)

Creates a new SocketConnectionFactory.

Parameters:

config - The MongoDB client configuration.

Method Detail

close

public void close()

Overridden to do nothing.

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.

Returns a new SocketConnection.

Specified by:

connect in interface ConnectionFactory

Returns:

The Connection to MongoDB.

Throws:

IOException - On a failure connecting to the server.

See Also:

ConnectionFactory.connect()

connect

public Connection connect(Server server,
                 MongoClientConfiguration config)
                   throws IOException

Creates a connection to the address provided.

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.

getCluster

public Cluster getCluster()

Returns the cluster state.

Returns:

The cluster state.

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.STAND_ALONE 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 SimpleReconnectStrategy.

Specified by:

getReconnectStrategy in interface ConnectionFactory

Returns:

The reconnection strategy for the type of connections.

configurationChanged

protected void configurationChanged(PropertyChangeEvent evt)

Notification of a change to the configuration of the client.

Parameters:

evt - The details of the configuration change.