com.mongodb.connection

Class DefaultServer

java.lang.Object

com.mongodb.connection.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.DefaultServerProtocolExecutor
private class	DefaultServer.DefaultServerStateListener

Field Summary

Fields

Modifier and Type	Field and Description
private ClusterConnectionMode	clusterConnectionMode
private CommandListener	commandListener
private ConnectionFactory	connectionFactory
private ConnectionPool	connectionPool
private ServerDescription	description
private boolean	isClosed
private static Logger	LOGGER
private ServerId	serverId
private ServerListener	serverListener
private ServerMonitor	serverMonitor
private ChangeListener<ServerDescription>	serverStateListener

Constructor Summary

Constructors

Constructor and Description
DefaultServer(ServerId serverId, ClusterConnectionMode clusterConnectionMode, ConnectionPool connectionPool, ConnectionFactory connectionFactory, ServerMonitorFactory serverMonitorFactory, java.util.List<ServerListener> serverListeners, CommandListener commandListener)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the server.
void	connect() Attempt to connect to the server.
Connection	getConnection() Gets a connection to this server.
void	getConnectionAsync(SingleResultCallback<AsyncConnection> callback) Gets a connection to this server asynchronously.
(package private) ConnectionPool	getConnectionPool()
ServerDescription	getDescription() Gets the description of this server.
private void	handleThrowable(java.lang.Throwable t)
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

LOGGER

private static final Logger LOGGER

serverId

private final ServerId serverId

connectionPool

private final ConnectionPool connectionPool

clusterConnectionMode

private final ClusterConnectionMode clusterConnectionMode

connectionFactory

private final ConnectionFactory connectionFactory

serverMonitor

private final ServerMonitor serverMonitor

serverStateListener

private final ChangeListener<ServerDescription> serverStateListener

serverListener

private final ServerListener serverListener

commandListener

private final CommandListener commandListener

description

private volatile ServerDescription description

isClosed

private volatile boolean isClosed

Constructor Detail

DefaultServer

public DefaultServer(ServerId serverId,
                     ClusterConnectionMode clusterConnectionMode,
                     ConnectionPool connectionPool,
                     ConnectionFactory connectionFactory,
                     ServerMonitorFactory serverMonitorFactory,
                     java.util.List<ServerListener> serverListeners,
                     CommandListener commandListener)

Method Detail

getConnection

public Connection getConnection()

Description copied from interface: Server

Gets a connection to this server. The connection should be released after the caller is done with it.

Implementations of this method are allowed to block while waiting for a free connection from a pool of available connection.

Implementations of this method will likely pool the underlying connection, so the effect of closing the returned connection will be to return the connection to the pool.

Specified by:

getConnection in interface Server

Returns:

a connection this server

getConnectionAsync

public void getConnectionAsync(SingleResultCallback<AsyncConnection> callback)

Description copied from interface: Server

Gets a connection to this server asynchronously. The connection should be released after the caller is done with it.

Implementations of this method will likely pool the underlying connection, so the effect of closing the returned connection will be to return the connection to the pool.

Specified by:

getConnectionAsync in interface Server

Parameters:

callback - the callback to execute when the connection is available or an error occurs

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{ServerConnectionState.CONNECTING} state.

Specified by:

getDescription in interface Server

Returns:

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

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

getConnectionPool

ConnectionPool getConnectionPool()

handleThrowable

private void handleThrowable(java.lang.Throwable t)