com.allanbank.mongodb.client

Class ClientImpl

java.lang.Object

com.allanbank.mongodb.client.AbstractClient

com.allanbank.mongodb.client.ClientImpl

All Implemented Interfaces:

Client

public class ClientImpl
extends AbstractClient

Implementation of the internal Client interface which all requests to the MongoDB servers pass.

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ClientImpl.ConnectionListener ConnectionListener provides the call back for events occurring on a connection.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG The logger for the ClientImpl.

Constructor Summary

Constructors

Constructor and Description
ClientImpl(MongoDbConfiguration config) Create a new ClientImpl.
ClientImpl(MongoDbConfiguration config, ConnectionFactory connectionFactory) Create a new ClientImpl.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the client.
protected Connection	findConnection(Message message1, Message message2) Locates a Connection to send a message on.
ClusterType	getClusterType() Returns the type of cluster the client is connected to.
MongoDbConfiguration	getConfig() Returns the configuration being used by the logical MongoDB connection.
Durability	getDefaultDurability() Returns the Durability from the MongoDbConfiguration.
ReadPreference	getDefaultReadPreference() Returns the ReadPreference from the MongoDbConfiguration.
protected void	handleConnectionClosed(Connection connection) Tries to reconnect previously open Connections.
protected void	reconnect(Connection connection) Runs the reconnect logic for the connection.

Methods inherited from class com.allanbank.mongodb.client.AbstractClient

send, send

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

Constructor Detail

ClientImpl

public ClientImpl(MongoDbConfiguration config)

Create a new ClientImpl.

Parameters:

config - The configuration for interacting with MongoDB.

ClientImpl

public ClientImpl(MongoDbConfiguration config,
          ConnectionFactory connectionFactory)

Create a new ClientImpl.

Parameters:

config - The configuration for interacting with MongoDB.

connectionFactory - The source of connection for the client.

Method Detail

close

public void close()

Closes the client.

Overridden to close all of the open connections.

See Also:

Closeable.close()

getClusterType

public ClusterType getClusterType()

Returns the type of cluster the client is connected to.

Overridden to return the ClusterType of the ConnectionFactory.

Returns:

The type of cluster the client is connected to.

getConfig

public MongoDbConfiguration getConfig()

Returns the configuration being used by the logical MongoDB connection.

Overridden to return the configuration used when the client was constructed.

Returns:

The configuration being used by the logical MongoDB connection.

getDefaultDurability

public Durability getDefaultDurability()

Returns the Durability from the MongoDbConfiguration.

Overridden to return the configurations default durability.

Returns:

The default durability from the MongoDbConfiguration.

See Also:

Client.getDefaultDurability()

getDefaultReadPreference

public ReadPreference getDefaultReadPreference()

Returns the ReadPreference from the MongoDbConfiguration.

Overridden to return the configurations default read preference.

Returns:

The default read preference from the MongoDbConfiguration .

See Also:

Client.getDefaultReadPreference()

findConnection

protected Connection findConnection(Message message1,
                        Message message2)
                             throws MongoDbException

Locates a Connection to send a message on.

Tries to locate a connection that can quickly dispatch the message to a MongoDB server. The basic metrics for determining if a connection is idle is to look at the number of messages waiting to be sent. The basic logic for finding a connection is:

1. Scan the list of connection looking for an idle connection. If one is found use it.
2. If there are no idle connections determine the maximum number of allowed connections and if there are fewer that the maximum allowed then take the connection creation lock, create a new connection, use it, and add to the set of available connections and release the lock.
3. If there are is still not a connection idle then sort the connections based on a snapshot of pending messages and use the connection with the least messages.

Specified by:

findConnection in class AbstractClient

Parameters:

message1 - The first message that will be sent. The connection return should be compatible with all of the messages ReadPreference.

message2 - The second message that will be sent. The connection return should be compatible with all of the messages ReadPreference. May be null.

Returns:

The Connection to send a message on.

Throws:

MongoDbException - In the case of an error finding a Connection.

handleConnectionClosed

protected void handleConnectionClosed(Connection connection)

Tries to reconnect previously open Connections. If a connection was being closed then cleans up the remaining state.

Parameters:

connection - The connection that was closed.

reconnect

protected void reconnect(Connection connection)

Runs the reconnect logic for the connection.

Parameters:

connection - The connection to reconnect.