Uses of Interface
com.allanbank.mongodb.connection.Connection

Packages that use Connection

Package	Description
com.allanbank.mongodb.client	Provides implementations of the main client interfaces and classes to translate the Reply(s) from the server.
com.allanbank.mongodb.connection	Provides interfaces for managing connections to different MongoDB server configurations.
com.allanbank.mongodb.connection.auth	Wraps a connection and ensures that all requests are properly authenticated.
com.allanbank.mongodb.connection.bootstrap	Bootstraps a the correct type of connections for the type of MongoDB cluster.
com.allanbank.mongodb.connection.proxy	Support for connection that delegate to a lower level connection.
com.allanbank.mongodb.connection.rs	Support for connections to Replica Sets.
com.allanbank.mongodb.connection.sharded	Support for connections to Sharded Configurations.
com.allanbank.mongodb.connection.socket	Low level socket connection to a single MongoDB server.
com.allanbank.mongodb.connection.state	Support for tracking the state of a set of MongoDB servers.

Uses of Connection in com.allanbank.mongodb.client

Methods in com.allanbank.mongodb.client that return Connection

Modifier and Type	Method and Description
protected Connection	ClientImpl.findConnection(Message message1, Message message2) Locates a Connection to send a message on.
protected Connection	SerialClientImpl.findConnection(Message message1, Message message2) Tries to reuse the last connection used.
protected abstract Connection	AbstractClient.findConnection(Message message1, Message message2) Locates a Connection to send a message on.
protected Connection	ClientImpl.searchConnection(Message message1, Message message2, boolean waitForReconnect) Searches for a connection to use.

Methods in com.allanbank.mongodb.client with parameters of type Connection

Modifier and Type	Method and Description
protected void	ClientImpl.handleConnectionClosed(Connection connection) Tries to reconnect previously open Connections.
protected void	ClientImpl.reconnect(Connection connection) Runs the reconnect logic for the connection.

Uses of Connection in com.allanbank.mongodb.connection

Methods in com.allanbank.mongodb.connection that return Connection

Modifier and Type	Method and Description
Connection	ConnectionFactory.connect() Creates a connection to the address provided.
Connection	ReconnectStrategy.reconnect(Connection oldConnection) Encapsulates the strategy for re-establishing the connection to the server.

Methods in com.allanbank.mongodb.connection with parameters of type Connection

Modifier and Type	Method and Description
Connection	ReconnectStrategy.reconnect(Connection oldConnection) Encapsulates the strategy for re-establishing the connection to the server.

Uses of Connection in com.allanbank.mongodb.connection.auth

Classes in com.allanbank.mongodb.connection.auth that implement Connection

Modifier and Type	Class and Description
class	AuthenticatingConnection AuthenticatingConnection provides a connection that authenticated with the server for each database before it is used.

Methods in com.allanbank.mongodb.connection.auth that return Connection

Modifier and Type	Method and Description
protected Connection	AuthenticatingConnection.getProxiedConnection() Returns the proxiedConnection value.

Methods in com.allanbank.mongodb.connection.auth with parameters of type Connection

Modifier and Type	Method and Description
void	Authenticator.startAuthentication(Credential credentials, Connection connection) Starts to authenticate the user with the specified credentials.
void	MongoDbAuthenticator.startAuthentication(Credential credential, Connection connection) Starts to authenticate the user with the specified credentials.

Constructors in com.allanbank.mongodb.connection.auth with parameters of type Connection

Constructor and Description
AuthenticatingConnection(Connection connection, MongoClientConfiguration config) Creates a new AuthenticatingConnection.

Uses of Connection in com.allanbank.mongodb.connection.bootstrap

Methods in com.allanbank.mongodb.connection.bootstrap that return Connection

Modifier and Type	Method and Description
Connection	BootstrapConnectionFactory.connect() Creates a connection to the address provided.

Uses of Connection in com.allanbank.mongodb.connection.proxy

Classes in com.allanbank.mongodb.connection.proxy that implement Connection

Modifier and Type	Class and Description
class	AbstractProxyConnection A helper class for constructing connections that are really just proxies on top of other connections.

Methods in com.allanbank.mongodb.connection.proxy that return Connection

Modifier and Type	Method and Description
Connection	ProxiedConnectionFactory.connect(ServerState server, MongoClientConfiguration config) Creates a connection to the address provided.
protected Connection	AbstractProxyConnection.getProxiedConnection() Returns the proxiedConnection value.

Constructors in com.allanbank.mongodb.connection.proxy with parameters of type Connection

Constructor and Description
AbstractProxyConnection(Connection proxiedConnection, MongoClientConfiguration config) Creates a AbstractProxyConnection.

Uses of Connection in com.allanbank.mongodb.connection.rs

Classes in com.allanbank.mongodb.connection.rs that implement Connection

Modifier and Type	Class and Description
class	ReplicaSetConnection Provides a Connection implementation for connecting to a replica-set environment.

Methods in com.allanbank.mongodb.connection.rs that return Connection

Modifier and Type	Method and Description
Connection	ReplicaSetConnectionFactory.connect() Creates a new connection to the replica set.
protected Connection	ReplicaSetConnection.reconnect(Connection conn) Reconnects the connection.

Methods in com.allanbank.mongodb.connection.rs with parameters of type Connection

Modifier and Type	Method and Description
protected ReplicaSetConnection	ReplicaSetReconnectStrategy.checkForReply(Connection oldConnection, Map<InetSocketAddress,Future<Reply>> answers, Map<InetSocketAddress,Connection> connections) Checks for a reply from a server.
protected String	ReplicaSetConnection.doSend(Connection conn, Message message1, Message message2, Callback<Reply> reply) Sends the message on the connection.
protected Connection	ReplicaSetConnection.reconnect(Connection conn) Reconnects the connection.
ReplicaSetConnection	ReplicaSetReconnectStrategy.reconnect(Connection oldConnection) Encapsulates the strategy for re-establishing the connection to the server.

Method parameters in com.allanbank.mongodb.connection.rs with type arguments of type Connection

Modifier and Type	Method and Description
protected ReplicaSetConnection	ReplicaSetReconnectStrategy.checkForReply(Connection oldConnection, Map<InetSocketAddress,Future<Reply>> answers, Map<InetSocketAddress,Connection> connections) Checks for a reply from a server.
protected String	ReplicaSetReconnectStrategy.checkReply(Future<Reply> replyFuture, Map<InetSocketAddress,Connection> connections, InetSocketAddress addr) Extracts who the server thinks is the primary from the reply.
protected Future<Reply>	ReplicaSetReconnectStrategy.sendIsPrimary(Map<InetSocketAddress,Future<Reply>> answers, Map<InetSocketAddress,Connection> connections, ServerState server, boolean isPrimary) Sends a command to the server to return what it thinks the state of the cluster is.
protected boolean	ReplicaSetReconnectStrategy.verifyPutative(Map<InetSocketAddress,Future<Reply>> answers, Map<InetSocketAddress,Connection> connections, String putativePrimary) Tries to verify that the suspected primary server is in fact the primary server by asking it directly and synchronously.

Constructors in com.allanbank.mongodb.connection.rs with parameters of type Connection

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

Uses of Connection in com.allanbank.mongodb.connection.sharded

Classes in com.allanbank.mongodb.connection.sharded that implement Connection

Modifier and Type	Class and Description
class	ShardedConnection Provides a Connection implementation for connecting to a sharded environment via mongos servers.

Methods in com.allanbank.mongodb.connection.sharded that return Connection

Modifier and Type	Method and Description
Connection	ShardedConnectionFactory.connect() Creates a new connection to the shared mongos servers.

Constructors in com.allanbank.mongodb.connection.sharded with parameters of type Connection

Constructor and Description
ShardedConnection(Connection proxiedConnection, MongoClientConfiguration config) Creates a new ShardedConnection.

Uses of Connection in com.allanbank.mongodb.connection.socket

Classes in com.allanbank.mongodb.connection.socket that implement Connection

Modifier and Type	Class and Description
class	SocketConnection Provides a blocking Socket based connection to a MongoDB server.

Methods in com.allanbank.mongodb.connection.socket that return Connection

Modifier and Type	Method and Description
Connection	SocketConnectionFactory.connect() Creates a connection to the address provided.
Connection	SocketConnectionFactory.connect(ServerState server, MongoClientConfiguration config) Creates a connection to the address provided.

Uses of Connection in com.allanbank.mongodb.connection.state

Methods in com.allanbank.mongodb.connection.state that return Connection

Modifier and Type	Method and Description
Connection	SimpleReconnectStrategy.reconnect(Connection oldConnection) Encapsulates the strategy for re-establishing the connection to the server.
Connection	ServerState.takeConnection() Returns a Connection to the server if one is available.

Methods in com.allanbank.mongodb.connection.state with parameters of type Connection

Modifier and Type	Method and Description
boolean	ServerState.addConnection(Connection connection) Adds a Connection to the state making it available for reuse.
protected void	AbstractReconnectStrategy.copyPending(Connection newConnection, Connection oldConnection) Copies the oldConnection pending messages to the newConnection.
protected boolean	AbstractReconnectStrategy.isConnected(ServerState server, Connection connection) Pings the server to verify that the connection is active.
static boolean	ClusterPinger.ping(InetSocketAddress addr, Connection conn) Pings the server and suppresses all exceptions.
boolean	ClusterPinger.Pinger.ping(InetSocketAddress addr, Connection conn, ServerState state) Pings the server and suppresses all exceptions.
Future<Reply>	ClusterPinger.Pinger.pingAsync(ClusterType type, InetSocketAddress addr, Connection conn, ServerState state) Pings the server and suppresses all exceptions.
Connection	SimpleReconnectStrategy.reconnect(Connection oldConnection) Encapsulates the strategy for re-establishing the connection to the server.