Package | Description |
---|---|
com.allanbank.mongodb.client |
Provides implementations of the main client interfaces and classes to translate the
Reply (s) from the server. |
com.allanbank.mongodb.client.callback |
Provides implementation for various transformations, implemented in the form of
Callback s, that are used by the driver. |
com.allanbank.mongodb.client.connection |
Provides interfaces for managing connections to different MongoDB server configurations.
|
com.allanbank.mongodb.client.connection.auth |
Wraps a connection and ensures that all requests are properly authenticated.
|
com.allanbank.mongodb.client.connection.proxy |
Support for connection that delegate to a lower level connection.
|
com.allanbank.mongodb.client.connection.rs |
Support for connections to Replica Sets.
|
com.allanbank.mongodb.client.connection.sharded |
Support for connections to Sharded Configurations.
|
com.allanbank.mongodb.client.connection.socket |
Low level socket connection to a single MongoDB server.
|
com.allanbank.mongodb.client.message |
Low level messages to be sent to the MongoDB server.
|
com.allanbank.mongodb.client.state |
Support for tracking the state of a set of MongoDB servers.
|
com.allanbank.mongodb.error |
Exceptions for common MongoDB error conditions.
|
Modifier and Type | Method and Description |
---|---|
protected Connection |
SerialClientImpl.findConnection(Message message1,
Message message2)
Tries to reuse the last connection used.
|
protected abstract Connection |
AbstractClient.findConnection(Message message1,
Message message2)
Locates a
Connection to send a message on. |
protected Connection |
ClientImpl.findConnection(Message message1,
Message message2)
Locates a
Connection to send a message on. |
protected Connection |
ClientImpl.searchConnection(Message message1,
Message message2,
boolean waitForReconnect)
Searches for a connection to use.
|
void |
AbstractClient.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
Client.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractClient.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
Client.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
int okValue,
int errorNumber,
boolean knownDurabilityError,
String errorMessage,
Message message)
Creates an exception from the parsed reply fields.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
Connection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthenticatingConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AuthenticatingConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
protected MongoDbException |
AbstractProxyMultipleConnection.createReconnectFailure(Message message1,
Message message2)
Creates a exception for a reconnect failure.
|
protected void |
AbstractProxyMultipleConnection.doSend(Connection conn,
Message message1,
Message message2,
ReplyCallback reply)
Sends the message on the connection.
|
protected abstract List<K> |
AbstractProxyMultipleConnection.findPotentialKeys(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
void |
AbstractProxyConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractProxyMultipleConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractProxyConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
AbstractProxyMultipleConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
protected boolean |
AbstractProxyMultipleConnection.trySend(List<K> servers,
Message message1,
Message message2,
ReplyCallback reply)
Tries to send the messages to the first server with either an open
connection or that we can open a connection to.
|
Modifier and Type | Method and Description |
---|---|
protected List<Server> |
ReplicaSetConnection.findPotentialKeys(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
Modifier and Type | Method and Description |
---|---|
protected List<Server> |
ShardedConnection.findPotentialKeys(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
AbstractSocketConnection.doReceive()
Receives a single message from the connection.
|
Modifier and Type | Method and Description |
---|---|
void |
SocketConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
TwoThreadSocketConnection.send(Message message1,
Message message2,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
SocketConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
void |
TwoThreadSocketConnection.send(Message message,
ReplyCallback replyCallback)
Sends a message on the connection.
|
protected void |
AbstractSocketConnection.validate(Message message1,
Message message2)
Ensures that the documents in the message do not exceed the maximum size
allowed by MongoDB.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CursorableMessage
CursorableMessage provides a common interface for messages that can start a
cursor.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessage
Base class for a MongoDB message.
|
class |
AdminCommand
Helper class to make generating administration command queries easier.
|
class |
AggregateCommand
Helper class for the aggregation commands.
|
class |
BatchedWriteCommand
BatchedWriteCommand provides a container to hold the batched write command
and the operations that it was created from.
|
class |
BuildInfo
Provides a convenient mechanism for creating a buildinfo
command.
|
class |
Command
Helper class to make generating command queries easier.
|
class |
CreateIndexCommand
Helper class to make generating a
createIndexes command easier. |
class |
Delete
Message to delete documents from a collection.
|
class |
GetLastError
Provides a convenient mechanism for creating a getlasterror
command.
|
class |
GetMore
Message to getmore documents from a cursor.
|
class |
Insert
Message to insert a set of documents into a collection.
|
class |
IsMaster
Provides a convenient mechanism for creating a ismaster
command.
|
class |
KillCursors
Message to killcursors that a client no longer needs.
|
class |
ParallelScanCommand
Helper class for the
parallelCollectionScan commands. |
class |
Query
Message to query documents from the database matching a criteria.
|
class |
ReplicaSetStatus
Provides a convenient mechanism for creating a replSetGetStatus command.
|
class |
Reply
Message received from the database in reply to a query.
|
class |
ServerStatus
Provides a convenient mechanism for creating a serverStatus command.
|
class |
Update
Message to apply an update to a document.
|
Modifier and Type | Method and Description |
---|---|
Message |
PendingMessage.getMessage()
Returns the sent message.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PendingMessageQueue.offer(Message message,
ReplyCallback replyCallback)
Puts a message onto the queue.
|
void |
PendingMessageQueue.put(Message message,
ReplyCallback replyCallback)
Puts a message onto the queue.
|
void |
PendingMessageQueue.put(Message message,
ReplyCallback replyCallback,
Message message2,
ReplyCallback replyCallback2)
Puts two messages onto the queue.
|
void |
PendingMessage.set(int messageId,
Message message,
ReplyCallback replyCallback)
Sets the state of the pending message.
|
Constructor and Description |
---|
PendingMessage(int messageId,
Message message)
Create a new PendingMessage.
|
PendingMessage(int messageId,
Message message,
ReplyCallback replyCallback)
Create a new PendingMessage.
|
Modifier and Type | Method and Description |
---|---|
List<Server> |
Cluster.findServers(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
Modifier and Type | Method and Description |
---|---|
Message |
ReplyException.getRequest()
Returns the original request message, if known.
|
Message |
MongoClientClosedException.getSentMessage()
Returns the message that was being sent.
|
Message |
ServerVersionException.getSentMessage()
Returns the operation's message.
|
Constructor and Description |
---|
DuplicateKeyException(int okValue,
int errorNumber,
String errorMessage,
Message message,
Reply reply)
Create a new DuplicateKeyException.
|
DurabilityException(int okValue,
int errorNumber,
String errorMessage,
Message message,
Reply reply)
Create a new DurabilityException.
|
MaximumTimeLimitExceededException(int okValue,
int errorNumber,
String errorMessage,
Message message,
Reply reply)
Create a new MaximumTimeLimitExceededException.
|
MongoClientClosedException(Message message)
Creates a new CannotConnectException.
|
ReplyException(int okValue,
int errorNumber,
String errorMessage,
Message request,
Reply reply)
Create a new ReplyException.
|
ServerVersionException(String operation,
VersionRange range,
Version actual,
Message message)
Creates a new ServerVersionException.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.