Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.event |
This package contains cluster and connection event related classes
|
Modifier and Type | Field and Description |
---|---|
private java.util.List<CommandListener> |
MongoClientOptions.commandListeners |
private java.util.List<CommandListener> |
MongoClientOptions.Builder.commandListeners |
Modifier and Type | Method and Description |
---|---|
private static CommandListener |
Mongo.createCommandListener(java.util.List<CommandListener> commandListeners) |
Modifier and Type | Method and Description |
---|---|
java.util.List<CommandListener> |
MongoClientOptions.getCommandListeners()
Gets the list of added
CommandListener . |
Modifier and Type | Method and Description |
---|---|
MongoClientOptions.Builder |
MongoClientOptions.Builder.addCommandListener(CommandListener commandListener)
Adds the given command listener.
|
Modifier and Type | Method and Description |
---|---|
private static CommandListener |
Mongo.createCommandListener(java.util.List<CommandListener> commandListeners) |
Modifier and Type | Field and Description |
---|---|
private java.util.List<CommandListener> |
MongoClientSettings.commandListeners |
private java.util.List<CommandListener> |
MongoClientSettings.Builder.commandListeners |
Modifier and Type | Method and Description |
---|---|
(package private) static CommandListener |
MongoClients.createCommandListener(java.util.List<CommandListener> commandListeners) |
Modifier and Type | Method and Description |
---|---|
java.util.List<CommandListener> |
MongoClientSettings.getCommandListeners()
Gets the list of added
CommandListener . |
Modifier and Type | Method and Description |
---|---|
MongoClientSettings.Builder |
MongoClientSettings.Builder.addCommandListener(CommandListener commandListener)
Adds the given command listener.
|
Modifier and Type | Method and Description |
---|---|
(package private) static CommandListener |
MongoClients.createCommandListener(java.util.List<CommandListener> commandListeners) |
Modifier and Type | Field and Description |
---|---|
private CommandListener |
DefaultServer.commandListener |
private CommandListener |
CommandProtocol.commandListener |
private CommandListener |
SendMessageCallback.commandListener |
private CommandListener |
WriteCommandProtocol.commandListener |
private CommandListener |
QueryProtocol.commandListener |
private CommandListener |
WriteProtocol.commandListener |
private CommandListener |
KillCursorProtocol.commandListener |
private CommandListener |
GetMoreProtocol.commandListener |
private CommandListener |
GetMoreProtocol.GetMoreResultCallback.commandListener |
private CommandListener |
DefaultClusterableServerFactory.commandListener |
Modifier and Type | Method and Description |
---|---|
CommandListener |
QueryProtocol.getCommandListener() |
Modifier and Type | Method and Description |
---|---|
Cluster |
DefaultClusterFactory.create(ClusterSettings settings,
ServerSettings serverSettings,
ConnectionPoolSettings connectionPoolSettings,
StreamFactory streamFactory,
StreamFactory heartbeatStreamFactory,
java.util.List<MongoCredential> credentialList,
ClusterListener clusterListener,
ConnectionPoolListener connectionPoolListener,
ConnectionListener connectionListener,
CommandListener commandListener)
Creates a cluster with the given settings.
|
Cluster |
DefaultClusterFactory.create(ClusterSettings settings,
ServerSettings serverSettings,
ConnectionPoolSettings connectionPoolSettings,
StreamFactory streamFactory,
StreamFactory heartbeatStreamFactory,
java.util.List<MongoCredential> credentialList,
ClusterListener clusterListener,
ConnectionPoolListener connectionPoolListener,
ConnectionListener connectionListener,
CommandListener commandListener,
java.lang.String applicationName,
MongoDriverInformation mongoDriverInformation)
Creates a cluster with the given settings.
|
(package private) static void |
ProtocolHelper.sendCommandFailedEvent(RequestMessage message,
java.lang.String commandName,
ConnectionDescription connectionDescription,
long startTimeNanos,
java.lang.Throwable throwable,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandStartedEvent(RequestMessage message,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command,
ConnectionDescription connectionDescription,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandSucceededEvent(RequestMessage message,
java.lang.String commandName,
BsonDocument response,
ConnectionDescription connectionDescription,
long startTimeNanos,
CommandListener commandListener) |
void |
CommandProtocol.setCommandListener(CommandListener commandListener) |
void |
WriteCommandProtocol.setCommandListener(CommandListener commandListener) |
void |
QueryProtocol.setCommandListener(CommandListener commandListener) |
void |
WriteProtocol.setCommandListener(CommandListener commandListener) |
void |
KillCursorProtocol.setCommandListener(CommandListener commandListener) |
void |
Protocol.setCommandListener(CommandListener commandListener) |
void |
GetMoreProtocol.setCommandListener(CommandListener commandListener) |
Constructor and Description |
---|
DefaultClusterableServerFactory(ClusterId clusterId,
ClusterSettings clusterSettings,
ServerSettings settings,
ConnectionPoolSettings connectionPoolSettings,
StreamFactory streamFactory,
StreamFactory heartbeatStreamFactory,
java.util.List<MongoCredential> credentialList,
ConnectionListener connectionListener,
ConnectionPoolListener connectionPoolListener,
CommandListener commandListener,
java.lang.String applicationName,
MongoDriverInformation mongoDriverInformation) |
DefaultServer(ServerId serverId,
ClusterConnectionMode clusterConnectionMode,
ConnectionPool connectionPool,
ConnectionFactory connectionFactory,
ServerMonitorFactory serverMonitorFactory,
java.util.List<ServerListener> serverListeners,
CommandListener commandListener) |
GetMoreResultCallback(SingleResultCallback<QueryResult<T>> callback,
long cursorId,
GetMoreMessage message,
ConnectionDescription connectionDescription,
CommandListener commandListener,
long startTimeNanos) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
int requestId,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
Modifier and Type | Class and Description |
---|---|
class |
CommandEventMulticaster
A multicaster for command events.
|
class |
CommandListenerMulticaster
Deprecated.
Prefer
CommandEventMulticaster |
Modifier and Type | Field and Description |
---|---|
private java.util.List<CommandListener> |
CommandEventMulticaster.commandListeners |
Modifier and Type | Method and Description |
---|---|
java.util.List<CommandListener> |
CommandEventMulticaster.getCommandListeners()
Gets the command listeners.
|
java.util.List<CommandListener> |
CommandListenerMulticaster.getCommandListeners()
Deprecated.
Gets the command listeners.
|
Constructor and Description |
---|
CommandEventMulticaster(java.util.List<CommandListener> commandListeners)
Construct an instance with the given list of command listeners
|
CommandListenerMulticaster(java.util.List<CommandListener> commandListeners)
Deprecated.
Construct an instance with the given list of command listeners
|