com.mongodb.internal.connection

Class MultiServerCluster

java.lang.Object

com.mongodb.internal.connection.MultiServerCluster

All Implemented Interfaces:

Cluster, java.io.Closeable, java.lang.AutoCloseable

public final class MultiServerCluster
extends java.lang.Object

This class needs to be final because we are leaking a reference to "this" from the constructor

Constructor Summary

Constructors

Constructor and Description
MultiServerCluster(ClusterId clusterId, ClusterSettings settings, ClusterableServerFactory serverFactory)

Method Summary

Modifier and Type	Method and Description
void	close() Closes connections to the servers in the cluster.
BsonTimestamp	getClusterTime() Get the last seen cluster time
ClusterDescription	getCurrentDescription() Get the current description of this cluster.
ClusterDescription	getDescription() Get the description of this cluster.
ClusterableServerFactory	getServerFactory()
ClusterSettings	getSettings() Gets the cluster settings with which this cluster was created.
boolean	isClosed() Whether all the servers in the cluster are closed or not.
Server	selectServer(ServerSelector serverSelector) Get a MongoDB server that matches the criteria defined by the serverSelector
void	selectServerAsync(ServerSelector serverSelector, SingleResultCallback<Server> callback) Asynchronously gets a MongoDB server that matches the criteria defined by the serverSelector.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiServerCluster

public MultiServerCluster(ClusterId clusterId,
                          ClusterSettings settings,
                          ClusterableServerFactory serverFactory)

Method Detail

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

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

getClusterTime

public BsonTimestamp getClusterTime()

Description copied from interface: Cluster

Get the last seen cluster time

Specified by:

getClusterTime in interface Cluster

Returns:

the last seen cluster time or null if not set

selectServer

public Server selectServer(ServerSelector serverSelector)

Description copied from interface: Cluster

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

Specified by:

selectServer in interface Cluster

Parameters:

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

Returns:

a Server that meets the requirements

selectServerAsync

public void selectServerAsync(ServerSelector serverSelector,
                              SingleResultCallback<Server> callback)

Description copied from interface: Cluster

Asynchronously gets a MongoDB server that matches the criteria defined by the serverSelector.

Specified by:

selectServerAsync in interface Cluster

Parameters:

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

callback - the callback to invoke when the server is found or an error occurs

getDescription

public ClusterDescription getDescription()

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

Returns:

a ClusterDescription representing the current state of the cluster

getSettings

public ClusterSettings getSettings()

Description copied from interface: Cluster

Gets the cluster settings with which this cluster was created.

Specified by:

getSettings in interface Cluster

Returns:

the cluster settings

getServerFactory

public ClusterableServerFactory getServerFactory()

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

getCurrentDescription

public ClusterDescription getCurrentDescription()

Description copied from interface: Cluster

Get the current description of this cluster.

Specified by:

getCurrentDescription in interface Cluster

Returns:

the current ClusterDescription representing the current state of the cluster.