com.mongodb

Class BaseCluster

java.lang.Object

com.mongodb.BaseCluster

All Implemented Interfaces:

Cluster

Direct Known Subclasses:

MultiServerCluster, SingleServerCluster

abstract class BaseCluster
extends java.lang.Object
implements Cluster

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	BaseCluster.WrappedServer

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	clusterId
private ClusterListener	clusterListener
private ClusterDescription	description
private boolean	isClosed
private static java.util.logging.Logger	LOGGER
private java.util.concurrent.atomic.AtomicReference<java.util.concurrent.CountDownLatch>	phase
private java.lang.ThreadLocal<java.util.Random>	random
private ClusterableServerFactory	serverFactory
private ClusterSettings	settings

Constructor Summary

Constructors

Constructor and Description
BaseCluster(java.lang.String clusterId, ClusterSettings settings, ClusterableServerFactory serverFactory, ClusterListener clusterListener)

Method Summary

Modifier and Type	Method and Description
void	close() Closes connections to the servers in the cluster.
protected abstract void	connect() Try to connect to all servers
protected ClusterableServer	createServer(ServerAddress serverAddress, ChangeListener<ServerDescription> serverStateListener)
protected void	fireChangeEvent()
(package private) ClusterDescription	getCurrentDescription()
ClusterDescription	getDescription(long maxWaitTime, java.util.concurrent.TimeUnit timeUnit) Get the description of this cluster.
private java.util.Random	getRandom()
private ClusterableServer	getRandomServer(java.util.List<ServerDescription> serverDescriptions)
protected abstract ClusterableServer	getServer(ServerAddress serverAddress) Return the server at the given address.
Server	getServer(ServerSelector serverSelector, long maxWaitTime, java.util.concurrent.TimeUnit timeUnit) Get a MongoDB server that matches the criteria defined by the serverSelector
ClusterSettings	getSettings()
boolean	isClosed() Whether all the servers in the cluster are closed or not.
private void	throwIfIncompatible(ClusterDescription curDescription)
protected void	updateDescription(ClusterDescription newDescription)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final java.util.logging.Logger LOGGER

phase

private final java.util.concurrent.atomic.AtomicReference<java.util.concurrent.CountDownLatch> phase

serverFactory

private final ClusterableServerFactory serverFactory

random

private final java.lang.ThreadLocal<java.util.Random> random

clusterId

private final java.lang.String clusterId

settings

private final ClusterSettings settings

clusterListener

private final ClusterListener clusterListener

isClosed

private volatile boolean isClosed

description

private volatile ClusterDescription description

Constructor Detail

BaseCluster

public BaseCluster(java.lang.String clusterId,
                   ClusterSettings settings,
                   ClusterableServerFactory serverFactory,
                   ClusterListener clusterListener)

Method Detail

getServer

public Server getServer(ServerSelector serverSelector,
                        long maxWaitTime,
                        java.util.concurrent.TimeUnit timeUnit)

Description copied from interface: Cluster

Get a MongoDB server that matches the criteria defined by the serverSelector

Specified by:

getServer in interface Cluster

Parameters:

serverSelector - a ServerSelector that defines how to select the required Server

maxWaitTime - the maximum time to wait for a connection to the cluster to get a server

timeUnit - the TimeUnit for the maxWaitTime

Returns:

a Server that meets the requirements

getDescription

public ClusterDescription getDescription(long maxWaitTime,
                                         java.util.concurrent.TimeUnit timeUnit)

Description copied from interface: Cluster

Get the description of this cluster. This method will not return normally until the cluster type is known.

Specified by:

getDescription in interface Cluster

Parameters:

maxWaitTime - the maximum time to wait for a connection to the cluster to get the description

timeUnit - the TimeUnit for the maxWaitTime

Returns:

a ClusterDescription representing the current state of the cluster

getSettings

public ClusterSettings getSettings()

close

public void close()

Description copied from interface: Cluster

Closes connections to the servers in the cluster. After this is called, this cluster instance can no longer be used.

Specified by:

close in interface Cluster

isClosed

public boolean isClosed()

Description copied from interface: Cluster

Whether all the servers in the cluster are closed or not.

Specified by:

isClosed in interface Cluster

Returns:

true if all the servers in this cluster have been closed

getServer

protected abstract ClusterableServer getServer(ServerAddress serverAddress)

Return the server at the given address.

Parameters:

serverAddress - the address

Returns:

the server, or null if the cluster no longer contains a server at this address.

connect

protected abstract void connect()

Try to connect to all servers

updateDescription

protected void updateDescription(ClusterDescription newDescription)

fireChangeEvent

protected void fireChangeEvent()

getCurrentDescription

ClusterDescription getCurrentDescription()

getRandomServer

private ClusterableServer getRandomServer(java.util.List<ServerDescription> serverDescriptions)

throwIfIncompatible

private void throwIfIncompatible(ClusterDescription curDescription)

getRandom

private java.util.Random getRandom()

createServer

protected ClusterableServer createServer(ServerAddress serverAddress,
                                         ChangeListener<ServerDescription> serverStateListener)