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.connection |
Provides interfaces for managing connections to different MongoDB server configurations.
|
com.allanbank.mongodb.connection.auth |
Wraps a connection and ensures that all requests are properly authenticated.
|
com.allanbank.mongodb.connection.message |
Low level messages to be sent to the MongoDB server.
|
com.allanbank.mongodb.connection.proxy |
Support for connection that delegate to a lower level connection.
|
com.allanbank.mongodb.connection.rs |
Support for connections to Replica Sets.
|
com.allanbank.mongodb.connection.socket |
Low level socket connection to a single MongoDB server.
|
com.allanbank.mongodb.error |
Exceptions for common MongoDB error conditions.
|
Modifier and Type | Method and Description |
---|---|
protected Connection |
ClientImpl.findConnection(Message message1,
Message message2)
Locates a
Connection to send a message on. |
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.searchConnection(Message message1,
Message message2,
boolean waitForReconnect)
Searches for a connection to use.
|
String |
Client.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
AbstractClient.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
Client.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
AbstractClient.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
String |
Connection.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
Connection.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
String |
AuthenticatingConnection.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
AuthenticatingConnection.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
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 |
Command
Helper class to make generating command queries 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 |
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 |
---|---|
void |
PendingMessageQueue.put(Message message,
Callback<Reply> replyCallback)
Puts a message onto the queue.
|
void |
PendingMessageQueue.put(Message message,
Callback<Reply> replyCallback,
Message message2,
Callback<Reply> replyCallback2)
Puts two messages onto the queue.
|
void |
PendingMessage.set(int messageId,
Message message,
Callback<Reply> 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,
Callback<Reply> replyCallback)
Create a new PendingMessage.
|
Modifier and Type | Method and Description |
---|---|
String |
AbstractProxyConnection.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
AbstractProxyConnection.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
Modifier and Type | Method and Description |
---|---|
protected String |
ReplicaSetConnection.doSend(Connection conn,
Message message1,
Message message2,
Callback<Reply> reply)
Sends the message on the connection.
|
protected List<ServerState> |
ReplicaSetConnection.findPotentialServers(Message message1,
Message message2)
Locates the set of servers that can be used to send the specified
messages.
|
String |
ReplicaSetConnection.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
ReplicaSetConnection.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
protected String |
ReplicaSetConnection.trySend(List<ServerState> servers,
Message message1,
Message message2,
Callback<Reply> reply)
Tries to send the messages to the first server with either an open
connection or that we can open a connection to.
|
protected String |
ReplicaSetConnection.trySendToOpenConnection(List<ServerState> servers,
Message message1,
Message message2,
Callback<Reply> reply)
Tries to send the messages to the first server with an open connection.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
SocketConnection.doReceive()
Receives a single message from the connection.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SocketConnection.doSend(int messageId,
Message message)
Sends a single message to the connection.
|
String |
SocketConnection.send(Message message,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
String |
SocketConnection.send(Message message1,
Message message2,
Callback<Reply> replyCallback)
Sends a message on the connection.
|
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.
|
Constructor and Description |
---|
MongoClientClosedException(Message message)
Creates a new CannotConnectException.
|
ReplyException(int okValue,
int errorNumber,
String errorMessage,
Message request,
Reply reply)
Create a new ReplyException.
|
Copyright © 2011-2013 Allanbank Consulting, Inc.. All Rights Reserved.