com.allanbank.mongodb.connection.state

Class AbstractReconnectStrategy

java.lang.Object

com.allanbank.mongodb.connection.state.AbstractReconnectStrategy

All Implemented Interfaces:

ReconnectStrategy

Direct Known Subclasses:

ReplicaSetReconnectStrategy, SimpleReconnectStrategy

public abstract class AbstractReconnectStrategy
extends Object
implements ReconnectStrategy

AbstractReconnectStrategy provides a base class for reconnection strategies.

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-2013, Allanbank Consulting, Inc., All Rights Reserved

Field Summary

Fields

Modifier and Type	Field and Description
protected MongoClientConfiguration	myConfig The configuration for connections to the servers.
protected ProxiedConnectionFactory	myConnectionFactory The connection factory for new connections.
protected ServerSelector	mySelector The selector for which server to connect to.
protected ClusterState	myState The state of the cluster.

Constructor Summary

Constructors

Constructor and Description
AbstractReconnectStrategy() Creates a new AbstractReconnectStrategy.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	copyPending(Connection newConnection, Connection oldConnection) Copies the oldConnection pending messages to the newConnection.
MongoClientConfiguration	getConfig() Returns the configuration for connections to the servers.
ProxiedConnectionFactory	getConnectionFactory() Returns the connection factory for new connections.
ServerSelector	getSelector() Returns the selector for which server to connect to.
ClusterState	getState() Returns the state of the cluster.
protected boolean	isConnected(ServerState server, Connection connection) Pings the server to verify that the connection is active.
void	setConfig(MongoClientConfiguration config) Sets the configuration to be used by the reconnection strategy.
void	setConnectionFactory(ProxiedConnectionFactory connectionFactory) Sets the connection factory to use to establish connections to the server.
void	setSelector(ServerSelector selector) Sets the selector to be used by the reconnection strategy.
void	setState(ClusterState state) Sets the state of the cluster to be used by the reconnection strategy.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.allanbank.mongodb.connection.ReconnectStrategy

reconnect

Field Detail

myConfig

protected MongoClientConfiguration myConfig

The configuration for connections to the servers.

myConnectionFactory

protected ProxiedConnectionFactory myConnectionFactory

The connection factory for new connections.

mySelector

protected ServerSelector mySelector

The selector for which server to connect to.

myState

protected ClusterState myState

The state of the cluster.

Constructor Detail

AbstractReconnectStrategy

public AbstractReconnectStrategy()

Creates a new AbstractReconnectStrategy.

Method Detail

getConfig

public MongoClientConfiguration getConfig()

Returns the configuration for connections to the servers.

Returns:

The configuration for connections to the servers

getConnectionFactory

public ProxiedConnectionFactory getConnectionFactory()

Returns the connection factory for new connections.

Returns:

The connection factory for new connections.

getSelector

public ServerSelector getSelector()

Returns the selector for which server to connect to.

Returns:

The selector for which server to connect to.

getState

public ClusterState getState()

Returns the state of the cluster.

Returns:

The state of the cluster.

setConfig

public void setConfig(MongoClientConfiguration config)

Sets the configuration to be used by the reconnection strategy.

Specified by:

setConfig in interface ReconnectStrategy

Parameters:

config - The configuration for the connections.

setConnectionFactory

public void setConnectionFactory(ProxiedConnectionFactory connectionFactory)

Sets the connection factory to use to establish connections to the server.

Specified by:

setConnectionFactory in interface ReconnectStrategy

Parameters:

connectionFactory - The connection factory to use to establish connections to the server.

setSelector

public void setSelector(ServerSelector selector)

Sets the selector to be used by the reconnection strategy.

Specified by:

setSelector in interface ReconnectStrategy

Parameters:

selector - The selector for connections.

setState

public void setState(ClusterState state)

Sets the state of the cluster to be used by the reconnection strategy.

Specified by:

setState in interface ReconnectStrategy

Parameters:

state - The state of the cluster.

copyPending

protected void copyPending(Connection newConnection,
               Connection oldConnection)

Copies the oldConnection pending messages to the newConnection.

Parameters:

newConnection - The connection to copy the messages to.

oldConnection - The connection to copy the messages from.

isConnected

protected boolean isConnected(ServerState server,
                  Connection connection)

Pings the server to verify that the connection is active.

Parameters:

server - The server being connected to.

connection - The connection to verify.

Returns:

True if the connection is working, false otherwise.