Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
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.state |
Support for tracking the state of a set of MongoDB servers.
|
Modifier and Type | Interface and Description |
---|---|
interface |
StreamCallback<V>
Extension of the
Callback interface to provide the ability to notify
callers when the stream is done. |
Modifier and Type | Method and Description |
---|---|
void |
AsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results)
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
Count count)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AsyncMongoCollection.countAsync(Callback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AsyncMongoCollection.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct command)
Invokes a distinct command on the server.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AsyncMongoCollection.explainAsync(Callback<Document> results,
Find query)
Explains the way that the query will be performed.
|
void |
AsyncMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
void |
AsyncMongoCollection.findOneAsync(Callback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(Callback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.findOneAsync(Callback<Document> results,
Find query)
Finds a single matching document in the collection.
|
void |
AsyncMongoCollection.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy command)
Invokes a group command on the server.
|
void |
AsyncMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(Callback<Integer> results,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AsyncMongoCollection.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AsyncMongoCollection.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
DocumentAssignable command,
Version requiredServerVersion)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabase.runCommandAsync(Callback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
AsyncMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
void |
AsyncMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
Use the
AsyncMongoCollection.streamingFind(StreamCallback, DocumentAssignable)
method instead. This method will be removed after the 1.3.0
release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find) method instead.
This method will be removed after the 1.3.0 release. |
void |
AsyncMongoCollection.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AsyncMongoCollection.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AsyncMongoCollection.writeAsync(Callback<Long> results,
BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AsyncMongoCollection.writeAsync(Callback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
Modifier and Type | Class and Description |
---|---|
class |
FutureCallback<V>
Implementation of a
Callback and ListenableFuture interfaces. |
class |
LambdaCallbackAdapter<V>
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractAsyncMongoCollection.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
AbstractMongoOperations.aggregateAsync(Callback<MongoIterator<Document>> results,
Aggregate command)
Constructs a
aggregate command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results)
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractMongoOperations.countAsync(Callback<Long> results,
Count count)
Constructs a
count command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractAsyncMongoCollection.countAsync(Callback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractMongoOperations.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
|
void |
AbstractAsyncMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractAsyncMongoCollection.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
AbstractMongoOperations.distinctAsync(Callback<MongoIterator<Element>> results,
Distinct command)
Constructs a
distinct command and sends it to the server via the
Client . |
protected void |
AbstractMongoOperations.doInsertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
Version requiredServerVersion,
DocumentAssignable... documents)
Sends an
Insert message to the server. |
protected void |
AbstractMongoOperations.doWriteAsync(ClusterStats stats,
Callback<Long> results,
BatchedWrite write)
Performs a async write operation.
|
void |
AbstractAsyncMongoCollection.explainAsync(Callback<Document> results,
Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
void |
AbstractMongoOperations.explainAsync(Callback<Document> results,
Aggregate aggregation)
Constructs a
AggregateCommand and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.explainAsync(Callback<Document> results,
Find.Builder query)
Explains the way that the query will be performed.
|
void |
AbstractMongoOperations.explainAsync(Callback<Document> results,
Find query)
|
void |
AbstractAsyncMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
AbstractMongoOperations.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Constructs a
findAndModify command and sends it to the server via
the Client . |
void |
AbstractAsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AbstractAsyncMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
AbstractMongoOperations.findAsync(Callback<MongoIterator<Document>> results,
Find query)
|
void |
AbstractAsyncMongoCollection.findOneAsync(Callback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AbstractAsyncMongoCollection.findOneAsync(Callback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
AbstractMongoOperations.findOneAsync(Callback<Document> results,
Find query)
|
void |
AbstractAsyncMongoCollection.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
AbstractMongoOperations.groupByAsync(Callback<MongoIterator<Element>> results,
GroupBy command)
Constructs a
group command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractMongoOperations.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
|
void |
AbstractAsyncMongoCollection.insertAsync(Callback<Integer> results,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractAsyncMongoCollection.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
AbstractMongoOperations.mapReduceAsync(Callback<MongoIterator<Document>> results,
MapReduce command)
Constructs a
mapreduce command and sends it to the server via the
Client . |
void |
AbstractAsyncMongoCollection.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
void |
AbstractMongoOperations.parallelScanAsync(Callback<Collection<MongoIterator<Document>>> results,
ParallelScan parallelScan)
Constructs a
parallelCollectionScan command and sends it to the
server via the Client . |
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
DocumentAssignable command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
DocumentAssignable command,
Version requireServerVersion)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String command)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String command,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
MongoDatabaseImpl.runCommandAsync(Callback<Document> reply,
String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
void |
AbstractAsyncMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
void |
AbstractMongoOperations.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Constructs a
Insert of Update message based on if the
document contains a AbstractMongoOperations.ID_FIELD_NAME and sends it to the server via
the Client . |
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
|
void |
AbstractAsyncMongoCollection.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AbstractMongoOperations.textSearchAsync(Callback<MongoIterator<TextResult>> results,
Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
void |
AbstractAsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
void |
AbstractMongoOperations.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
|
void |
AbstractAsyncMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractAsyncMongoCollection.writeAsync(Callback<Long> results,
BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
void |
AbstractMongoOperations.writeAsync(Callback<Long> results,
BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ReplyCallback
ReplyCallback provides an interface for the receive processing to determine
is a callback can be safely called on the receiver's thread.
|
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 |
BatchedInsertCountingCallback
BatchedInsertCountingCallback is designed to work with the
BatchedWriteCallback . |
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 |
IteratorToListCallbackAdapter
IteratorToListCallbackAdapter provides the ability to translate a
MongoIterator callback into a list callback.
|
class |
LegacyStreamCallbackAdapter
Deprecated.
Deprecated to ensure this class is removed with the
AsyncMongoCollection.streamingFind(Callback, com.allanbank.mongodb.bson.DocumentAssignable)
and
AsyncMongoCollection.streamingFind(Callback, com.allanbank.mongodb.builder.Find)
methods. |
class |
LongToIntCallback
LongToIntCallback provides a simple callback wrapper to convert the long
value to an integer.
|
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 |
TextCallback
Deprecated.
Support for the
text command was deprecated in the 2.6
version of MongoDB. Use the $text query operator instead. This class will not be removed
until two releases after the MongoDB 2.6 release (e.g. 2.10 if
the releases are 2.8 and 2.10). |
class |
ValidatingReplyCallback
ValidatingCallback to expect and extract a single document from the reply.
|
Modifier and Type | Method and Description |
---|---|
Callback<F> |
AbstractReplyCallback.getForwardCallback()
Returns the forwardCallback value.
|
Constructor and Description |
---|
AbstractReplyCallback(Callback<F> forwardCallback)
Create a new AbstractReplyCallback.
|
BatchedInsertCountingCallback(Callback<Reply> forwardCallback,
int expectedCount)
Creates a new CountingCallback.
|
BatchedNativeWriteCallback(Callback<Long> results,
BatchedWrite write,
AbstractMongoOperations collection,
List<WriteOperation> operations)
Creates a new BatchedWriteCallback.
|
BatchedWriteCallback(String databaseName,
String collectionName,
Callback<Long> results,
BatchedWrite write,
Client client,
List<BatchedWrite.Bundle> bundles)
Creates a new BatchedWriteCallback.
|
CursorCallback(Client client,
CursorableMessage message,
boolean command,
Callback<MongoIterator<Document>> results)
Create a new CursorCallback.
|
IteratorToListCallbackAdapter(Callback<List<Document>> delegate)
Creates a new IteratorToListCallbackAdapter.
|
LegacyStreamCallbackAdapter(Callback<Document> delegate)
Deprecated.
Creates a new LegacyStreamCallbackAdapter.
|
LongToIntCallback(Callback<Integer> delegate)
Creates a new LongToIntCallback.
|
MultipleCursorCallback(Client client,
CursorableMessage message,
Callback<Collection<MongoIterator<Document>>> results)
Create a new CursorCallback.
|
ReplyArrayCallback(Callback<MongoIterator<Element>> results)
Create a new ReplyDocumentCallback.
|
ReplyArrayCallback(String name,
Callback<MongoIterator<Element>> results)
Create a new ReplyDocumentCallback.
|
ReplyCommandCallback(Callback<Document> results)
Create a new ReplyDocumentCallback.
|
ReplyDocumentCallback(Callback<Document> results)
Create a new ReplyDocumentCallback.
|
ReplyDocumentCallback(String name,
Callback<Document> results)
Create a new ReplyDocumentCallback.
|
ReplyIntegerCallback(Callback<Integer> results)
Create a new ReplyIntegerCallback.
|
ReplyIntegerCallback(String name,
Callback<Integer> results)
Create a new ReplyIntegerCallback.
|
ReplyLongCallback(Callback<Long> results)
Create a new ReplyLongCallback.
|
ReplyLongCallback(String name,
Callback<Long> results)
Create a new ReplyLongCallback.
|
ReplyResultCallback(Callback<MongoIterator<Document>> forwardCallback)
Create a new ReplyResultCallback.
|
ReplyResultCallback(String field,
Callback<MongoIterator<Document>> forwardCallback)
Create a new ReplyResultCallback.
|
SingleDocumentCallback(Callback<Document> results)
Create a new CursorCallback.
|
SingleDocumentReplyCallback(Callback<Document> results)
Create a new SingleDocumentReplyCallback.
|
TextCallback(Callback<MongoIterator<TextResult>> delegate)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This class will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
Constructor and Description |
---|
BatchedWriteCallback(String databaseName,
String collectionName,
List<Callback<Reply>> realCallbacks,
BatchedWrite write,
List<BatchedWrite.Bundle> bundles)
Creates a new BatchedWriteCallback.
|
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.