com.allanbank.mongodb.connection.rs

Class ReplicaSetConnection

java.lang.Object

com.allanbank.mongodb.connection.proxy.AbstractProxyConnection

com.allanbank.mongodb.connection.rs.ReplicaSetConnection

All Implemented Interfaces:

Connection, Closeable, Flushable, AutoCloseable

public class ReplicaSetConnection
extends AbstractProxyConnection

Provides a Connection implementation for connecting 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-2013, Allanbank Consulting, Inc., All Rights Reserved

Nested Class Summary

Nested classes/interfaces inherited from class com.allanbank.mongodb.connection.proxy.AbstractProxyConnection

AbstractProxyConnection.ProxiedChangeListener

Field Summary

Fields

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

Fields inherited from class com.allanbank.mongodb.connection.proxy.AbstractProxyConnection

myConfig

Fields inherited from interface com.allanbank.mongodb.connection.Connection

COMMAND_COLLECTION, OPEN_PROP_NAME

Constructor Summary

Constructors

Constructor and Description
ReplicaSetConnection(Connection proxiedConnection, ServerState server, ClusterState cluster, ProxiedConnectionFactory factory, MongoClientConfiguration config) Creates a new ReplicaSetConnection.

Method Summary

Methods

Modifier and Type	Method and Description
protected String	doSend(Connection conn, Message message1, Message message2, Callback<Reply> reply) Sends the message on the connection.
protected List<ServerState>	findPotentialServers(Message message1, Message message2) Locates the set of servers that can be used to send the specified messages.
protected Connection	reconnect(Connection conn) Reconnects the connection.
String	send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.
String	toString()
protected String	trySend(List<ServerState> servers, Message message1, Message message2, Callback<Reply> reply) Tries to send the messages to the first server with either an open connection or that we can open a connection to.
protected String	trySendToOpenConnection(List<ServerState> servers, Message message1, Message message2, Callback<Reply> reply) Tries to send the messages to the first server with an open connection.

Methods inherited from class com.allanbank.mongodb.connection.proxy.AbstractProxyConnection

addPending, addPropertyChangeListener, close, drainPending, flush, getPendingCount, getProxiedConnection, getServerName, isIdle, isOpen, onExceptin, raiseErrors, removePropertyChangeListener, shutdown, waitForClosed

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

The logger for the ReplicaSetConnectionFactory.

Constructor Detail

ReplicaSetConnection

public ReplicaSetConnection(Connection proxiedConnection,
                    ServerState server,
                    ClusterState cluster,
                    ProxiedConnectionFactory factory,
                    MongoClientConfiguration config)

Creates a new ReplicaSetConnection.

Parameters:

proxiedConnection - The connection being proxied.

server - The primary server this connection is connected to.

cluster - The state of the cluster for finding secondary connections.

factory - The connection factory for opening secondary connections.

config - The MongoDB client configuration.

Method Detail

send

public String send(Message message,
          Callback<Reply> replyCallback)
            throws MongoDbException

Sends a message on the connection.

Forwards the call to the proxied Connection.

Locates all of the potential servers that can receive all of the messages. Tries to then send the messages to a server with a connection already open or failing that tries to open a connection to open of the servers.

Specified by:

send in interface Connection

Overrides:

send in class AbstractProxyConnection

Parameters:

message - The message to send on the connection.

replyCallback - The callback to notify of responses to the messages. May be null.

Returns:

The server that was sent the request.

Throws:

MongoDbException - On an error sending the message.

send

public String send(Message message1,
          Message message2,
          Callback<Reply> replyCallback)
            throws MongoDbException

Sends a message on the connection.

Forwards the call to the proxied Connection.

Locates all of the potential servers that can receive all of the messages. Tries to then send the messages to a server with a connection already open or failing that tries to open a connection to open of the servers.

Specified by:

send in interface Connection

Overrides:

send in class AbstractProxyConnection

Parameters:

message1 - The first message to send on the connection.

message2 - The second message to send on the connection.

replyCallback - The callback to notify of responses to the message2. May be null.

Returns:

The server that was sent the request.

Throws:

MongoDbException - On an error sending the message.

toString

public String toString()

Overridden to return the socket information.

Overrides:

toString in class Object

doSend

protected String doSend(Connection conn,
            Message message1,
            Message message2,
            Callback<Reply> reply)

Sends the message on the connection.

Parameters:

conn - The connection to send on.

message1 - The first message to send.

message2 - The second message to send, may be null.

reply - The reply Callback.

Returns:

The server the message was sent to.

findPotentialServers

protected List<ServerState> findPotentialServers(Message message1,
                                     Message message2)
                                          throws MongoDbException

Locates the set of servers that can be used to send the specified messages.

Parameters:

message1 - The first message to send.

message2 - The second message to send. May be null.

Returns:

The servers that can be used.

Throws:

MongoDbException - On a failure to locate a server that all messages can be sent to.

reconnect

protected Connection reconnect(Connection conn)

Reconnects the connection.

Parameters:

conn - The connection to reconnect.

Returns:

The new connection if the reconnect was successful.

trySend

protected String trySend(List<ServerState> servers,
             Message message1,
             Message message2,
             Callback<Reply> reply)

Tries to send the messages to the first server with either an open connection or that we can open a connection to.

Parameters:

servers - The servers the messages can be sent to.

message1 - The first message to send.

message2 - The second message to send. May be null.

reply - The callback for the replies.

Returns:

The token for the server that the messages were sent to or null if the messages could not be sent.

trySendToOpenConnection

protected String trySendToOpenConnection(List<ServerState> servers,
                             Message message1,
                             Message message2,
                             Callback<Reply> reply)

Tries to send the messages to the first server with an open connection.

Parameters:

servers - The servers the messages can be sent to.

message1 - The first message to send.

message2 - The second message to send. May be null.

reply - The callback for the replies.

Returns:

The token for the server that the messages were sent to or null if the messages could not be sent.