com.allanbank.mongodb.client

Class SerialClientImpl

java.lang.Object

com.allanbank.mongodb.client.AbstractClient

com.allanbank.mongodb.client.SerialClientImpl

All Implemented Interfaces:

Client

public class SerialClientImpl
extends AbstractClient

A specialization of the ClientImpl to always try to use the same connection.

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

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	ASSERTIONS_ENABLED If true then assertions have been enabled for the class.
protected static Logger	LOG The logger for the SerialClientImpl.

Constructor Summary

Constructors

Constructor and Description
SerialClientImpl(ClientImpl client) Create a new SerialClientImpl.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the client.
protected Connection	findConnection(Message message1, Message message2) Tries to reuse the last connection used.
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.

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

ASSERTIONS_ENABLED

protected static final boolean ASSERTIONS_ENABLED

If true then assertions have been enabled for the class.

LOG

protected static final Logger LOG

The logger for the SerialClientImpl.

Constructor Detail

SerialClientImpl

public SerialClientImpl(ClientImpl client)

Create a new SerialClientImpl.

Parameters:

client - The delegate client for accessing connections.

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

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

Tries to reuse the last connection used. If the connection it closed or does not exist then the request is delegated to the ClientImpl and the result cached for future requests.

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 found connection.

Throws:

MongoDbException - On a failure to talk to the MongoDB servers.