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.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.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 |
---|---|
List<Document> |
MongoCollection.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
List<Document> |
MongoCollection.aggregate(Aggregate command)
Invokes a aggregate command on the server.
|
Future<List<Document>> |
MongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Future<List<Document>> |
MongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
void |
MongoCollection.aggregateAsync(Callback<List<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
void |
MongoCollection.aggregateAsync(Callback<List<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
long |
MongoCollection.count()
Counts the set of documents in the collection.
|
long |
MongoCollection.count(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
long |
MongoCollection.count(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
long |
MongoCollection.count(ReadPreference readPreference)
Counts the set of documents in the collection.
|
Future<Long> |
MongoCollection.countAsync()
Counts the set of documents in the collection.
|
void |
MongoCollection.countAsync(Callback<Long> results)
Counts the set of documents in the collection.
|
void |
MongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
void |
MongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
MongoCollection.countAsync(Callback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
Future<Long> |
MongoCollection.countAsync(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
Future<Long> |
MongoCollection.countAsync(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
Future<Long> |
MongoCollection.countAsync(ReadPreference readPreference)
Counts the set of documents in the collection.
|
boolean |
MongoDatabase.createCappedCollection(String name,
long size)
Creates the capped collection with the specified name and size on the
server.
|
boolean |
MongoDatabase.createCollection(String name,
DocumentAssignable options)
Creates the collection with the specified name on the server.
|
void |
MongoCollection.createIndex(boolean unique,
Element... keys)
Creates an index with a generated name, across the keys specified and if
unique is true ensuring entries are unique.
|
void |
MongoCollection.createIndex(DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
MongoCollection.createIndex(Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
MongoCollection.createIndex(String name,
boolean unique,
Element... keys)
Creates an index with the specified name, across the keys specified and
if unique is true ensuring entries are unique.
|
void |
MongoCollection.createIndex(String name,
DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
long |
MongoCollection.delete(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
long |
MongoCollection.delete(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
long |
MongoCollection.delete(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
long |
MongoCollection.delete(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
MongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
MongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
void |
MongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
MongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
MongoCollection.deleteAsync(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
MongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
MongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
MongoCollection.deleteAsync(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ArrayElement |
MongoCollection.distinct(Distinct.Builder command)
Invokes a distinct command on the server.
|
ArrayElement |
MongoCollection.distinct(Distinct command)
Invokes a distinct command on the server.
|
void |
MongoCollection.distinctAsync(Callback<ArrayElement> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
void |
MongoCollection.distinctAsync(Callback<ArrayElement> results,
Distinct command)
Invokes a distinct command on the server.
|
Future<ArrayElement> |
MongoCollection.distinctAsync(Distinct.Builder command)
Invokes a distinct command on the server.
|
Future<ArrayElement> |
MongoCollection.distinctAsync(Distinct command)
Invokes a distinct command on the server.
|
boolean |
MongoDatabase.drop()
Drops the database.
|
boolean |
MongoCollection.drop()
Drops the collection from the database.
|
boolean |
MongoCollection.dropIndex(IntegerElement... keys)
Deletes the indexes matching the keys specified.
|
boolean |
MongoCollection.dropIndex(String name)
Deletes the indexes with the provided name.
|
Document |
MongoCollection.explain(DocumentAssignable query)
Explains the way that the document will be performed.
|
Document |
MongoCollection.explain(Find.Builder query)
Explains the way that the document will be performed.
|
Document |
MongoCollection.explain(Find query)
Explains the way that the document will be performed.
|
void |
MongoCollection.explainAsync(Callback<Document> results,
Find.Builder query)
Explains the way that the document will be performed.
|
void |
MongoCollection.explainAsync(Callback<Document> results,
Find query)
Explains the way that the document will be performed.
|
Future<Document> |
MongoCollection.explainAsync(Find.Builder query)
Explains the way that the document will be performed.
|
Future<Document> |
MongoCollection.explainAsync(Find query)
Explains the way that the document will be performed.
|
MongoIterator<Document> |
MongoCollection.find(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
MongoIterator<Document> |
MongoCollection.find(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
MongoIterator<Document> |
MongoCollection.find(Find query)
Finds the set of documents matching the query in the collection.
|
Document |
MongoCollection.findAndModify(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
Document |
MongoCollection.findAndModify(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
MongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
void |
MongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
Future<Document> |
MongoCollection.findAndModifyAsync(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
Future<Document> |
MongoCollection.findAndModifyAsync(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
MongoCollection.findAsync(Callback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
MongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
void |
MongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
Future<MongoIterator<Document>> |
MongoCollection.findAsync(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
Future<MongoIterator<Document>> |
MongoCollection.findAsync(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
Future<MongoIterator<Document>> |
MongoCollection.findAsync(Find query)
Finds the set of documents matching the query in the collection.
|
Document |
MongoCollection.findOne(DocumentAssignable query)
Finds a single matching document in the collection.
|
Document |
MongoCollection.findOne(Find.Builder query)
Finds a single matching document in the collection.
|
Document |
MongoCollection.findOne(Find query)
Finds a single matching document in the collection.
|
void |
MongoCollection.findOneAsync(Callback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
MongoCollection.findOneAsync(Callback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
void |
MongoCollection.findOneAsync(Callback<Document> results,
Find query)
Finds a single matching document in the collection.
|
Future<Document> |
MongoCollection.findOneAsync(DocumentAssignable query)
Finds a single matching document in the collection.
|
Future<Document> |
MongoCollection.findOneAsync(Find.Builder query)
Finds a single matching document in the collection.
|
Future<Document> |
MongoCollection.findOneAsync(Find query)
Finds a single matching document in the collection.
|
ProfilingStatus |
MongoDatabase.getProfilingStatus()
Retrieves the profiling level for the database.
|
ArrayElement |
MongoCollection.groupBy(GroupBy.Builder command)
Invokes a group command on the server.
|
ArrayElement |
MongoCollection.groupBy(GroupBy command)
Invokes a group command on the server.
|
void |
MongoCollection.groupByAsync(Callback<ArrayElement> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
void |
MongoCollection.groupByAsync(Callback<ArrayElement> results,
GroupBy command)
Invokes a group command on the server.
|
Future<ArrayElement> |
MongoCollection.groupByAsync(GroupBy.Builder command)
Invokes a group command on the server.
|
Future<ArrayElement> |
MongoCollection.groupByAsync(GroupBy command)
Invokes a group command on the server.
|
int |
MongoCollection.insert(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.insert(DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
MongoCollection.insert(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
MongoCollection.insertAsync(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
MongoCollection.insertAsync(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
MongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
MongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
MongoCollection.insertAsync(Callback<Integer> results,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
MongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
MongoCollection.insertAsync(DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
MongoCollection.insertAsync(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
boolean |
MongoCollection.isCapped()
Returns true if the collection
statistics indicate that
the collection is a capped collection. |
List<String> |
MongoDatabase.listCollectionNames()
Returns the list of the collections contained within the database.
|
List<String> |
MongoDatabase.listCollections()
Deprecated.
Use the
MongoDatabase.listCollectionNames() method instead. |
List<Document> |
MongoCollection.mapReduce(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
List<Document> |
MongoCollection.mapReduce(MapReduce command)
Invokes a mapReduce command on the server.
|
void |
MongoCollection.mapReduceAsync(Callback<List<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
void |
MongoCollection.mapReduceAsync(Callback<List<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
Future<List<Document>> |
MongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
Future<List<Document>> |
MongoCollection.mapReduceAsync(MapReduce command)
Invokes a mapReduce command on the server.
|
Document |
MongoDatabase.runAdminCommand(String command)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabase.runAdminCommand(String command,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabase.runAdminCommand(String commandName,
String commandValue,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabase.runCommand(String command)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String command,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabase.runCommand(String commandName,
String commandValue,
DocumentAssignable options)
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.
|
Future<Document> |
MongoDatabase.runCommandAsync(String command)
Runs a command against the database.
|
Future<Document> |
MongoDatabase.runCommandAsync(String command,
DocumentAssignable options)
Runs a command against the database.
|
Future<Document> |
MongoDatabase.runCommandAsync(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
Future<Document> |
MongoDatabase.runCommandAsync(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
int |
MongoCollection.save(DocumentAssignable document)
Saves the
document to the collection. |
int |
MongoCollection.save(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
MongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
void |
MongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
Future<Integer> |
MongoCollection.saveAsync(DocumentAssignable document)
Saves the
document to the collection. |
Future<Integer> |
MongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
boolean |
MongoDatabase.setProfilingStatus(ProfilingStatus profileLevel)
Sets the profiling level for the database.
|
Document |
MongoDatabase.stats()
Returns the statistics for the database.
|
Document |
MongoCollection.stats()
Returns the statistics for the collection.
|
MongoCursorControl |
MongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
Use the
MongoCollection.streamingFind(StreamCallback, DocumentAssignable)
method instead. This method will be removed after the 1.3.0
release. |
MongoCursorControl |
MongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
Use the
MongoCollection.streamingFind(StreamCallback, Find) method
instead. This method will be removed after the 1.3.0 release. |
MongoCursorControl |
MongoCollection.streamingFind(StreamCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
MongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
MongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
List<TextResult> |
MongoCollection.textSearch(Text.Builder command)
Invokes a
text command on the server. |
List<TextResult> |
MongoCollection.textSearch(Text command)
Invokes a
text command on the server. |
void |
MongoCollection.textSearchAsync(Callback<List<TextResult>> results,
Text.Builder command)
Invokes a
text command on the server. |
void |
MongoCollection.textSearchAsync(Callback<List<TextResult>> results,
Text command)
Invokes a
text command on the server. |
Future<List<TextResult>> |
MongoCollection.textSearchAsync(Text.Builder command)
Invokes a
text command on the server. |
Future<List<TextResult>> |
MongoCollection.textSearchAsync(Text command)
Invokes a
text command on the server. |
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
long |
MongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
MongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
MongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
void |
MongoCollection.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 |
MongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
Future<Long> |
MongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
Future<Long> |
MongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
Future<Long> |
MongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
Future<Long> |
MongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
Document |
MongoCollection.updateOptions(DocumentAssignable options)
Updates the collection's options or flags using the
collMod
command. |
Document |
MongoCollection.validate(MongoCollection.ValidateMode mode)
Validates the collections contents.
|
Modifier and Type | Method and Description |
---|---|
protected MongoDbException |
AbstractValidatingReplyCallback.asError(Reply reply)
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,
String errorMessage)
Creates an exception from the parsed reply fields.
|
Modifier and Type | Method and Description |
---|---|
List<Document> |
AbstractMongoCollection.aggregate(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
List<Document> |
AbstractMongoCollection.aggregate(Aggregate command)
Invokes a aggregate command on the server.
|
Future<List<Document>> |
AbstractMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
Future<List<Document>> |
AbstractMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
void |
AbstractMongoCollection.aggregateAsync(Callback<List<Document>> results,
Aggregate.Builder command)
Invokes a aggregate command on the server.
|
abstract void |
AbstractMongoCollection.aggregateAsync(Callback<List<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
void |
MongoCollectionImpl.aggregateAsync(Callback<List<Document>> results,
Aggregate command)
Invokes a aggregate command on the server.
|
protected void |
AbstractValidatingReplyCallback.checkForError(Reply reply)
Checks for a non-flag error in the reply.
|
protected List<Document> |
ReplyResultCallback.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. |
long |
AbstractMongoCollection.count()
Counts the set of documents in the collection.
|
long |
AbstractMongoCollection.count(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
long |
AbstractMongoCollection.count(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
long |
AbstractMongoCollection.count(ReadPreference readPreference)
Counts the set of documents in the collection.
|
Future<Long> |
AbstractMongoCollection.countAsync()
Counts the set of documents in the collection.
|
void |
AbstractMongoCollection.countAsync(Callback<Long> results)
Counts the set of documents in the collection.
|
void |
AbstractMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
abstract void |
AbstractMongoCollection.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
MongoCollectionImpl.countAsync(Callback<Long> results,
DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
void |
AbstractMongoCollection.countAsync(Callback<Long> results,
ReadPreference readPreference)
Counts the set of documents in the collection.
|
Future<Long> |
AbstractMongoCollection.countAsync(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
Future<Long> |
AbstractMongoCollection.countAsync(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
Future<Long> |
AbstractMongoCollection.countAsync(ReadPreference readPreference)
Counts the set of documents in the collection.
|
boolean |
MongoDatabaseImpl.createCappedCollection(String name,
long size)
Creates the capped collection with the specified name and size on the
server.
|
boolean |
MongoDatabaseImpl.createCollection(String name,
DocumentAssignable options)
Creates the collection with the specified name on the server.
|
void |
AbstractMongoCollection.createIndex(boolean unique,
Element... keys)
Creates an index with a generated name, across the keys specified and if
unique is true ensuring entries are unique.
|
void |
AbstractMongoCollection.createIndex(DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
AbstractMongoCollection.createIndex(Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
AbstractMongoCollection.createIndex(String name,
boolean unique,
Element... keys)
Creates an index with the specified name, across the keys specified and
if unique is true ensuring entries are unique.
|
abstract void |
AbstractMongoCollection.createIndex(String name,
DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
void |
MongoCollectionImpl.createIndex(String name,
DocumentAssignable options,
Element... keys)
Creates an index with a generated name, across the keys specified
allowing duplicate entries.
|
long |
AbstractMongoCollection.delete(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
long |
AbstractMongoCollection.delete(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
long |
AbstractMongoCollection.delete(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
long |
AbstractMongoCollection.delete(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
abstract void |
AbstractMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
MongoCollectionImpl.deleteAsync(Callback<Long> results,
DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
void |
AbstractMongoCollection.deleteAsync(Callback<Long> results,
DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
AbstractMongoCollection.deleteAsync(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
AbstractMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
AbstractMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
Future<Long> |
AbstractMongoCollection.deleteAsync(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ArrayElement |
AbstractMongoCollection.distinct(Distinct.Builder command)
Invokes a distinct command on the server.
|
ArrayElement |
AbstractMongoCollection.distinct(Distinct command)
Invokes a distinct command on the server.
|
void |
AbstractMongoCollection.distinctAsync(Callback<ArrayElement> results,
Distinct.Builder command)
Invokes a distinct command on the server.
|
abstract void |
AbstractMongoCollection.distinctAsync(Callback<ArrayElement> results,
Distinct command)
Invokes a distinct command on the server.
|
void |
MongoCollectionImpl.distinctAsync(Callback<ArrayElement> results,
Distinct command)
Invokes a distinct command on the server.
|
Future<ArrayElement> |
AbstractMongoCollection.distinctAsync(Distinct.Builder command)
Invokes a distinct command on the server.
|
Future<ArrayElement> |
AbstractMongoCollection.distinctAsync(Distinct command)
Invokes a distinct command on the server.
|
boolean |
AbstractMongoCollection.dropIndex(IntegerElement... keys)
Deletes the indexes matching the keys specified.
|
abstract boolean |
AbstractMongoCollection.dropIndex(String name)
Deletes the indexes with the provided name.
|
boolean |
MongoCollectionImpl.dropIndex(String name)
Deletes the indexes with the provided name.
|
Document |
AbstractMongoCollection.explain(DocumentAssignable query)
Explains the way that the document will be performed.
|
Document |
AbstractMongoCollection.explain(Find.Builder query)
Explains the way that the document will be performed.
|
Document |
AbstractMongoCollection.explain(Find query)
Explains the way that the document will be performed.
|
void |
AbstractMongoCollection.explainAsync(Callback<Document> results,
Find.Builder query)
Explains the way that the document will be performed.
|
abstract void |
AbstractMongoCollection.explainAsync(Callback<Document> results,
Find query)
Explains the way that the document will be performed.
|
void |
MongoCollectionImpl.explainAsync(Callback<Document> results,
Find query)
Explains the way that the document will be performed.
|
Future<Document> |
AbstractMongoCollection.explainAsync(Find.Builder query)
Explains the way that the document will be performed.
|
Future<Document> |
AbstractMongoCollection.explainAsync(Find query)
Explains the way that the document will be performed.
|
MongoIterator<Document> |
AbstractMongoCollection.find(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
MongoIterator<Document> |
AbstractMongoCollection.find(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
MongoIterator<Document> |
AbstractMongoCollection.find(Find query)
Finds the set of documents matching the query in the collection.
|
Document |
AbstractMongoCollection.findAndModify(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
Document |
AbstractMongoCollection.findAndModify(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AbstractMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
abstract void |
AbstractMongoCollection.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
MongoCollectionImpl.findAndModifyAsync(Callback<Document> results,
FindAndModify command)
Invokes a findAndModify command on the server.
|
Future<Document> |
AbstractMongoCollection.findAndModifyAsync(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
Future<Document> |
AbstractMongoCollection.findAndModifyAsync(FindAndModify command)
Invokes a findAndModify command on the server.
|
void |
AbstractMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
void |
AbstractMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find.Builder query)
Finds the set of documents matching the query in the collection.
|
abstract void |
AbstractMongoCollection.findAsync(Callback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
void |
MongoCollectionImpl.findAsync(Callback<MongoIterator<Document>> results,
Find query)
Finds the set of documents matching the query in the collection.
|
Future<MongoIterator<Document>> |
AbstractMongoCollection.findAsync(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
Future<MongoIterator<Document>> |
AbstractMongoCollection.findAsync(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
Future<MongoIterator<Document>> |
AbstractMongoCollection.findAsync(Find query)
Finds the set of documents matching the query in the collection.
|
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. |
Document |
AbstractMongoCollection.findOne(DocumentAssignable query)
Finds a single matching document in the collection.
|
Document |
AbstractMongoCollection.findOne(Find.Builder query)
Finds a single matching document in the collection.
|
Document |
AbstractMongoCollection.findOne(Find query)
Overridden to call the
AbstractMongoCollection.findOneAsync(Callback, Find) . |
void |
AbstractMongoCollection.findOneAsync(Callback<Document> results,
DocumentAssignable query)
Finds a single matching document in the collection.
|
void |
AbstractMongoCollection.findOneAsync(Callback<Document> results,
Find.Builder query)
Finds a single matching document in the collection.
|
abstract void |
AbstractMongoCollection.findOneAsync(Callback<Document> results,
Find query)
Finds a single matching document in the collection.
|
void |
MongoCollectionImpl.findOneAsync(Callback<Document> results,
Find query)
Finds a single matching document in the collection.
|
Future<Document> |
AbstractMongoCollection.findOneAsync(DocumentAssignable query)
Finds a single matching document in the collection.
|
Future<Document> |
AbstractMongoCollection.findOneAsync(Find.Builder query)
Finds a single matching document in the collection.
|
Future<Document> |
AbstractMongoCollection.findOneAsync(Find query)
Finds a single matching document in the collection.
|
ProfilingStatus |
MongoDatabaseImpl.getProfilingStatus()
Retrieves the profiling level for the database.
|
ArrayElement |
AbstractMongoCollection.groupBy(GroupBy.Builder command)
Invokes a group command on the server.
|
ArrayElement |
AbstractMongoCollection.groupBy(GroupBy command)
Invokes a group command on the server.
|
void |
AbstractMongoCollection.groupByAsync(Callback<ArrayElement> results,
GroupBy.Builder command)
Invokes a group command on the server.
|
abstract void |
AbstractMongoCollection.groupByAsync(Callback<ArrayElement> results,
GroupBy command)
Invokes a group command on the server.
|
void |
MongoCollectionImpl.groupByAsync(Callback<ArrayElement> results,
GroupBy command)
Invokes a group command on the server.
|
Future<ArrayElement> |
AbstractMongoCollection.groupByAsync(GroupBy.Builder command)
Invokes a group command on the server.
|
Future<ArrayElement> |
AbstractMongoCollection.groupByAsync(GroupBy command)
Invokes a group command on the server.
|
int |
AbstractMongoCollection.insert(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
AbstractMongoCollection.insert(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
AbstractMongoCollection.insert(DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
int |
AbstractMongoCollection.insert(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
AbstractMongoCollection.insertAsync(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
AbstractMongoCollection.insertAsync(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
abstract void |
AbstractMongoCollection.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
MongoCollectionImpl.insertAsync(Callback<Integer> results,
boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractMongoCollection.insertAsync(Callback<Integer> results,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
void |
AbstractMongoCollection.insertAsync(Callback<Integer> results,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
AbstractMongoCollection.insertAsync(DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
Future<Integer> |
AbstractMongoCollection.insertAsync(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
boolean |
MongoCollectionImpl.isCapped()
Returns true if the collection
statistics indicate that
the collection is a capped collection. |
List<Document> |
AbstractMongoCollection.mapReduce(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
List<Document> |
AbstractMongoCollection.mapReduce(MapReduce command)
Invokes a mapReduce command on the server.
|
void |
AbstractMongoCollection.mapReduceAsync(Callback<List<Document>> results,
MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
abstract void |
AbstractMongoCollection.mapReduceAsync(Callback<List<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
void |
MongoCollectionImpl.mapReduceAsync(Callback<List<Document>> results,
MapReduce command)
Invokes a mapReduce command on the server.
|
Future<List<Document>> |
AbstractMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
Future<List<Document>> |
AbstractMongoCollection.mapReduceAsync(MapReduce command)
Invokes a mapReduce command on the server.
|
void |
MongoIteratorImpl.restart()
Restarts the iterator by sending a request for more documents.
|
Document |
MongoDatabaseImpl.runAdminCommand(String command)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabaseImpl.runAdminCommand(String command,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabaseImpl.runAdminCommand(String commandName,
String commandValue,
DocumentAssignable options)
Runs an administrative command against the 'admin' database.
|
Document |
MongoDatabaseImpl.runCommand(String command)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String command,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
Document |
MongoDatabaseImpl.runCommand(String commandName,
String commandValue,
DocumentAssignable options)
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.
|
Future<Document> |
MongoDatabaseImpl.runCommandAsync(String command)
Runs a command against the database.
|
Future<Document> |
MongoDatabaseImpl.runCommandAsync(String command,
DocumentAssignable options)
Runs a command against the database.
|
Future<Document> |
MongoDatabaseImpl.runCommandAsync(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
Future<Document> |
MongoDatabaseImpl.runCommandAsync(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
int |
AbstractMongoCollection.save(DocumentAssignable document)
Saves the
document to the collection. |
int |
AbstractMongoCollection.save(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
AbstractMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document)
Saves the
document to the collection. |
abstract void |
AbstractMongoCollection.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
void |
MongoCollectionImpl.saveAsync(Callback<Integer> results,
DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
Future<Integer> |
AbstractMongoCollection.saveAsync(DocumentAssignable document)
Saves the
document to the collection. |
Future<Integer> |
AbstractMongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
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.
|
protected void |
MongoIteratorImpl.sendRequest()
Sends a request for more documents.
|
boolean |
MongoDatabaseImpl.setProfilingStatus(ProfilingStatus profileLevel)
Sets the profiling level for the database.
|
Document |
MongoDatabaseImpl.stats()
Returns the statistics for the database.
|
Document |
MongoCollectionImpl.stats()
Returns the statistics for the collection.
|
MongoCursorControl |
AbstractMongoCollection.streamingFind(Callback<Document> results,
DocumentAssignable query)
Deprecated.
|
MongoCursorControl |
AbstractMongoCollection.streamingFind(Callback<Document> results,
Find query)
Deprecated.
|
MongoCursorControl |
AbstractMongoCollection.streamingFind(StreamCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
abstract MongoCursorControl |
AbstractMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
MongoCollectionImpl.streamingFind(StreamCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
List<TextResult> |
AbstractMongoCollection.textSearch(Text.Builder command)
Invokes a
text command on the server. |
List<TextResult> |
AbstractMongoCollection.textSearch(Text command)
Invokes a
text command on the server. |
void |
AbstractMongoCollection.textSearchAsync(Callback<List<TextResult>> results,
Text.Builder command)
Invokes a
text command on the server. |
abstract void |
AbstractMongoCollection.textSearchAsync(Callback<List<TextResult>> results,
Text command)
Invokes a
text command on the server. |
void |
MongoCollectionImpl.textSearchAsync(Callback<List<TextResult>> results,
Text command)
Invokes a
text command on the server. |
Future<List<TextResult>> |
AbstractMongoCollection.textSearchAsync(Text.Builder command)
Invokes a
text command on the server. |
Future<List<TextResult>> |
AbstractMongoCollection.textSearchAsync(Text command)
Invokes a
text command on the server. |
long |
AbstractMongoCollection.update(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
long |
AbstractMongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
long |
AbstractMongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
long |
AbstractMongoCollection.update(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
void |
AbstractMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
void |
AbstractMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
abstract void |
AbstractMongoCollection.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 |
MongoCollectionImpl.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 |
AbstractMongoCollection.updateAsync(Callback<Long> results,
DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
Future<Long> |
AbstractMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
Future<Long> |
AbstractMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
Future<Long> |
AbstractMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
Future<Long> |
AbstractMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
Document |
MongoCollectionImpl.updateOptions(DocumentAssignable options)
Updates the collection's options or flags using the
collMod
command. |
Document |
MongoCollectionImpl.validate(MongoCollection.ValidateMode mode)
Validates the collections contents.
|
protected void |
AbstractValidatingReplyCallback.verify(Reply reply)
Checks the reply for an error message.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.raiseErrors(MongoDbException exception,
boolean notifyToBeSent)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
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 | Method and Description |
---|---|
protected void |
AbstractProxyConnection.onExceptin(MongoDbException exception)
Provides the ability for derived classes to intercept any exceptions from
the underlying proxied connection.
|
void |
AbstractProxyConnection.raiseErrors(MongoDbException exception,
boolean notifyToBeSent)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
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 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.
|
Modifier and Type | Field and Description |
---|---|
static MongoDbException |
SocketConnection.NO_REPLY
Exception that there was no reply for a message from MongoDB.
|
Modifier and Type | Method and Description |
---|---|
void |
SocketConnection.raiseErrors(MongoDbException exception,
boolean notifyToBeSent)
Notifies the call backs for the pending and optionally the to be sent
messages that there has been an external, unrecoverable error.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
SocketConnection.doReceive()
Receives a single message from 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 | Class and Description |
---|---|
class |
CannotConnectException
CannotConnectException is thrown to report a failure when attempting to
connect to MongoDB.
|
class |
ConnectionLostException
ConnectionLostException provides a exception thrown when the connection to
the MongoDB server is lost.
|
class |
CursorNotFoundException
Exception raised when a get_more request is issued for an unknown cursor.
|
class |
DocumentToLargeException
DocumentToLargeException is thrown to report that an attempt was made to
serialize a Document that is over the maximum size limit.
|
class |
DuplicateKeyException
Exception raised when an insert encounters a duplicate key error.
|
class |
JsonException
JsonException provides an exception to throw when processing JSON documents
fail.
|
class |
JsonParseException
JsonParseException provides an exception to throw when parsing a JSON
document fails.
|
class |
MongoClientClosedException
MongoClientClosedException is thrown when there is an attempt to send a
message on a closed
MongoClient . |
class |
MongoDbAuthenticationException
MongoDbAuthenticationException is thrown to report a failure to authenticate
with a MongoDB database.
|
class |
QueryFailedException
Exception raised when a query fails.
|
class |
ReplyException
Base class exception for all reply errors.
|
class |
ShardConfigStaleException
Exception raised when a a request to a shard server is based on an invalid or
stale configuration.
|
Copyright © 2011-2013 Allanbank Consulting, Inc.. All Rights Reserved.