| 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
Callbacks, that are used by the driver. |
| com.allanbank.mongodb.client.connection.rs |
Support for connections to Replica Sets.
|
| com.allanbank.mongodb.client.connection.socket |
Low level socket connection to a single 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 long |
MongoIteratorImpl.retreiveCursorIdFromPendingRequest(long cursorId,
Future<Reply> replyFuture)
If the current cursor id is zero then waits for the response from the
pending request to determine the real cursor id.
|
| Constructor and Description |
|---|
MongoIteratorImpl(CursorableMessage originalQuery,
Client client,
String server,
Reply reply)
Create a new MongoDBInterator.
|
| Modifier and Type | Method and Description |
|---|---|
protected Reply |
ValidatingReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
| Modifier and Type | Method and Description |
|---|---|
protected MongoDbException |
ReplyIntegerCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
ReplyLongCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
ReplyCommandCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
SingleDocumentReplyCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
ReplyDocumentCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
ReplyArrayCallback.asError(Reply reply)
Creates an exception from the
Reply. |
protected MongoDbException |
ReplyCommandCallback.asError(Reply reply,
boolean knownError)
Creates an exception from the
Reply. |
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
boolean knownError)
Creates an exception from the
Reply. |
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
int okValue,
int errorNumber,
boolean knownDurabilityError,
String errorMessage,
Message message)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
CursorCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
MultipleCursorCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected MongoDbException |
CursorStreamingCallback.asError(Reply reply,
int okValue,
int errorNumber,
String errorMessage)
Creates an exception from the parsed reply fields.
|
protected void |
BatchedWriteCallback.callback(BatchedWrite.Bundle bundle,
Reply result)
Callback for a bundle of write operations sent via the write commands.
|
void |
BatchedInsertCountingCallback.callback(Reply result)
Called when the MongoDB operation has completed with the result of the
operation.
|
void |
AbstractValidatingReplyCallback.callback(Reply result)
Called when the MongoDB operation has completed with the result of the
operation.
|
void |
NoOpCallback.callback(Reply result)
Called when the MongoDB operation has completed with the result of the
operation.
|
protected void |
AbstractValidatingReplyCallback.checkForError(Reply reply)
Checks for a non-flag error in the reply.
|
protected Integer |
ReplyIntegerCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected MongoIterator<Document> |
CursorCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Long |
ReplyLongCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Collection<MongoIterator<Document>> |
MultipleCursorCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
ReplyCommandCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
SingleDocumentReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected abstract F |
AbstractReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Reply |
ValidatingReplyCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
SingleDocumentCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected Document |
ReplyDocumentCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected MongoIterator<Element> |
ReplyArrayCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected MongoIterator<Document> |
ReplyResultCallback.convert(Reply reply)
Converts the
Reply into the final response type. |
protected void |
CursorCallback.handle(Reply reply)
Called once the
Reply has been validated. |
protected void |
MultipleCursorCallback.handle(Reply reply)
Called once the
Reply has been validated. |
protected void |
AbstractReplyCallback.handle(Reply reply)
Called once the
Reply has been validated. |
protected abstract void |
AbstractValidatingReplyCallback.handle(Reply reply)
Called once the
Reply has been validated. |
protected void |
CursorStreamingCallback.handle(Reply reply)
Called once the
Reply has been validated. |
protected List<Document> |
CursorStreamingCallback.loadDocuments(Reply reply)
Loads more documents.
|
static void |
ReplyHandler.reply(Receiver receiver,
Reply reply,
ReplyCallback replyCallback,
Executor executor)
Updates to set the reply for the callback, if any.
|
protected void |
AbstractValidatingReplyCallback.verify(Reply reply)
Checks the reply for an error message.
|
| Constructor and Description |
|---|
ReplyHandler(ReplyCallback replyCallback,
Reply reply)
Creates a new ReplyHandler.
|
| Constructor and Description |
|---|
BatchedInsertCountingCallback(Callback<Reply> forwardCallback,
int expectedCount)
Creates a new CountingCallback.
|
BatchedWriteCallback(String databaseName,
String collectionName,
List<Callback<Reply>> realCallbacks,
BatchedWrite write,
List<BatchedWrite.Bundle> bundles)
Creates a new BatchedWriteCallback.
|
| Modifier and Type | Method and Description |
|---|---|
protected Future<Reply> |
ReplicaSetReconnectStrategy.sendIsPrimary(Map<Server,Future<Reply>> answers,
Map<Server,Connection> connections,
Server server,
boolean isPrimary)
Sends a command to the server to return what it thinks the state of the
cluster is.
|
| Modifier and Type | Method and Description |
|---|---|
protected ConnectionInfo<Server> |
ReplicaSetReconnectStrategy.checkForReply(Cluster state,
Map<Server,Future<Reply>> answers,
Map<Server,Connection> connections,
long deadline)
Checks for a reply from a server.
|
protected String |
ReplicaSetReconnectStrategy.checkReply(Future<Reply> replyFuture,
Map<Server,Connection> connections,
Server server,
long deadline)
Extracts who the server thinks is the primary from the reply.
|
protected Future<Reply> |
ReplicaSetReconnectStrategy.sendIsPrimary(Map<Server,Future<Reply>> answers,
Map<Server,Connection> connections,
Server server,
boolean isPrimary)
Sends a command to the server to return what it thinks the state of the
cluster is.
|
protected boolean |
ReplicaSetReconnectStrategy.verifyPutative(Map<Server,Future<Reply>> answers,
Map<Server,Connection> connections,
Server putativePrimary,
long deadline)
Tries to verify that the suspected primary server is in fact the primary
server by asking it directly and synchronously.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractSocketConnection.reply(Reply reply,
PendingMessage pendingMessage)
Updates to set the reply for the callback, if any.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Reply> |
ClusterPinger.Pinger.pingAsync(ClusterType type,
Server server,
Connection conn)
Pings the server and suppresses all exceptions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ServerUpdateCallback.callback(Reply result)
Called when the MongoDB operation has completed with the result of the
operation.
|
| Modifier and Type | Method and Description |
|---|---|
Reply |
ReplyException.getReply()
Returns the reply.
|
| Constructor and Description |
|---|
CursorNotFoundException(Reply reply,
String message)
Create a new CursorNotFoundException.
|
CursorNotFoundException(Reply reply,
Throwable cause)
Create a new CursorNotFoundException.
|
DuplicateKeyException(int okValue,
int errorNumber,
String errorMessage,
Message message,
Reply reply)
Create a new DuplicateKeyException.
|
DuplicateKeyException(int okValue,
int errorNumber,
String errorMessage,
Reply reply)
Create a new DuplicateKeyException.
|
DurabilityException(int okValue,
int errorNumber,
String errorMessage,
Message message,
Reply reply)
Create a new DurabilityException.
|
DurabilityException(int okValue,
int errorNumber,
String errorMessage,
Reply reply)
Create a new DurabilityException.
|
MaximumTimeLimitExceededException(int okValue,
int errorNumber,
String errorMessage,
Message message,
Reply reply)
Create a new MaximumTimeLimitExceededException.
|
QueryFailedException(Reply reply,
Throwable cause)
Create a new QueryFailedException.
|
ReplyException(int okValue,
int errorNumber,
String errorMessage,
Message request,
Reply reply)
Create a new ReplyException.
|
ReplyException(int okValue,
int errorNumber,
String errorMessage,
Reply reply)
Create a new ReplyException.
|
ReplyException(Reply reply)
Create a new ReplyException.
|
ReplyException(Reply reply,
String message)
Create a new ReplyException.
|
ReplyException(Reply reply,
Throwable cause)
Create a new ReplyException.
|
ShardConfigStaleException(Reply reply,
Throwable cause)
Create a new ShardConfigStaleException.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.