com.mongodb

Class DefaultServer

java.lang.Object

com.mongodb.DefaultServer

All Implemented Interfaces:

ClusterableServer, Server

class DefaultServer
extends java.lang.Object
implements ClusterableServer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DefaultServer.DefaultServerStateListener

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<ChangeListener<ServerDescription>,java.lang.Boolean>	changeListeners
private PooledConnectionProvider	connectionProvider
private ServerDescription	description
private boolean	isClosed
private ServerAddress	serverAddress
private ServerMonitor	serverMonitor
private ChangeListener<ServerDescription>	serverStateListener

Constructor Summary

Constructors

Constructor and Description
DefaultServer(ServerAddress serverAddress, ServerSettings settings, java.lang.String clusterId, PooledConnectionProvider connectionProvider, Mongo mongo)

Method Summary

Modifier and Type	Method and Description
void	addChangeListener(ChangeListener<ServerDescription> changeListener) Adds a change listener to this server.
void	close() Closes the server.
void	connect() Attempt to connect to the server.
Connection	getConnection(long maxWaitTime, java.util.concurrent.TimeUnit timeUnit)
ServerDescription	getDescription() Gets the description of this server.
void	invalidate() Invalidate the description of this server.
boolean	isClosed() Returns true if the server is closed, false otherwise.

Methods inherited from class java.lang.Object

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

Field Detail

serverAddress

private final ServerAddress serverAddress

serverMonitor

private final ServerMonitor serverMonitor

connectionProvider

private final PooledConnectionProvider connectionProvider

changeListeners

private final java.util.Map<ChangeListener<ServerDescription>,java.lang.Boolean> changeListeners

serverStateListener

private final ChangeListener<ServerDescription> serverStateListener

description

private volatile ServerDescription description

isClosed

private volatile boolean isClosed

Constructor Detail

DefaultServer

public DefaultServer(ServerAddress serverAddress,
                     ServerSettings settings,
                     java.lang.String clusterId,
                     PooledConnectionProvider connectionProvider,
                     Mongo mongo)

Method Detail

getDescription

public ServerDescription getDescription()

Description copied from interface: Server

Gets the description of this server. Implementations of this method should not block if the server has not yet been successfully contacted, but rather return immediately a @code{ServerDescription} in a @code{ServerDescription.Status.Connecting} state.

Specified by:

getDescription in interface Server

Returns:

the description of this server

getConnection

public Connection getConnection(long maxWaitTime,
                                java.util.concurrent.TimeUnit timeUnit)

Specified by:

getConnection in interface Server

addChangeListener

public void addChangeListener(ChangeListener<ServerDescription> changeListener)

Description copied from interface: ClusterableServer

Adds a change listener to this server.

Specified by:

addChangeListener in interface ClusterableServer

Parameters:

changeListener - the listener for change events to the description of this server

invalidate

public void invalidate()

Description copied from interface: ClusterableServer

Invalidate the description of this server. Implementation of this method should not block, but rather trigger an asynchronous attempt to connect with the server in order to determine its current status.

Specified by:

invalidate in interface ClusterableServer

Specified by:

invalidate in interface Server

close

public void close()

Description copied from interface: ClusterableServer

Closes the server. Instances that have been closed will no longer be available for use.

Implementations should ensure that this method can be called multiple times with no ill effects.

Specified by:

close in interface ClusterableServer

isClosed

public boolean isClosed()

Description copied from interface: ClusterableServer

Returns true if the server is closed, false otherwise.

Specified by:

isClosed in interface ClusterableServer

Returns:

whether the server is closed

connect

public void connect()

Description copied from interface: ClusterableServer

Attempt to connect to the server.

Specified by:

connect in interface ClusterableServer