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.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.
|
Modifier and Type | Method and Description |
---|---|
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 | Class and Description |
---|---|
class |
AbstractReplyCallback<F>
Helper class for constructing callbacks that convert a
Reply message
into a different type of result. |
class |
AbstractValidatingReplyCallback
Helper class for constructing callbacks that convert a
Reply message
into a different type of result. |
class |
BatchedNativeWriteCallback
BatchedWriteCallback provides the global callback for the batched writes when
the server does not support the write commands.
|
class |
BatchedWriteCallback
BatchedWriteCallback provides the global callback for the batched writes.
|
class |
CursorCallback
|
class |
CursorStreamingCallback
Callback to convert a
CursorableMessage Reply into a series
of callback for each document received. |
class |
FutureReplyCallback
FutureReplyCallback provides a
FutureCallback that also implements
the ReplyCallback interface. |
class |
MultipleCursorCallback
|
class |
NoOpCallback
NoOpCallback provides a callback that does nothing.
|
class |
ReplyArrayCallback
Callback to expect and extract a single document from the reply and then
extract its contained array.
|
class |
ReplyCommandCallback
Callback to expect and extract a single document from the reply.
|
class |
ReplyDocumentCallback
Callback to expect and extract a single document from the reply and then
extract its contained document.
|
class |
ReplyIntegerCallback
Callback to expect and extract a single document from the reply and then
extract a contained
NumericElement and coerce it to a integer value. |
class |
ReplyLongCallback
Callback to expect and extract a single document from the reply and then
extract a contained
NumericElement and coerce it to a long value. |
class |
ReplyResultCallback
Callback to extract the map/reduce and aggregation results from the reply.
|
class |
SingleDocumentCallback
Callback to convert a
Reply into a single document. |
class |
SingleDocumentReplyCallback
Callback to expect and extract a single document from the reply.
|
class |
ValidatingReplyCallback
ValidatingCallback to expect and extract a single document from the reply.
|
Modifier and Type | Method and Description |
---|---|
static void |
ReplyHandler.raiseError(Throwable exception,
ReplyCallback replyCallback,
Executor executor)
Raise an error on the callback, if any.
|
static void |
ReplyHandler.reply(Receiver receiver,
Reply reply,
ReplyCallback replyCallback,
Executor executor)
Updates to set the reply for the callback, if any.
|
Constructor and Description |
---|
ReplyHandler(ReplyCallback replyCallback,
Reply reply)
Creates a new ReplyHandler.
|
ReplyHandler(ReplyCallback replyCallback,
Throwable exception)
Creates a new ReplyHandler.
|
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 void |
AbstractProxyMultipleConnection.doSend(Connection conn,
Message message1,
Message message2,
ReplyCallback reply)
Sends the message on the connection.
|
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 void |
AbstractSocketConnection.raiseError(Throwable exception,
ReplyCallback replyCallback)
Updates to raise an error on the callback, if any.
|
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.
|
Modifier and Type | Method and Description |
---|---|
ReplyCallback |
PendingMessage.getReplyCallback()
Returns the callback for the reply to the 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,
ReplyCallback replyCallback)
Create a new PendingMessage.
|
Modifier and Type | Class and Description |
---|---|
class |
ServerUpdateCallback
ServerUpdateCallback provides a special callback update the server with the
first document in the reply.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.