public class

MongoCloudConnectorCapabilitiesAdapter

extends MongoCloudConnector
implements Capabilities

java.lang.Object
↳	org.mule.module.mongo.MongoCloudConnector
	↳	org.mule.module.mongo.adapters.MongoCloudConnectorCapabilitiesAdapter

Known Direct Subclasses

MongoCloudConnectorLifecycleAdapter

Class Overview

A MongoCloudConnectorCapabilitiesAdapter is a wrapper around MongoCloudConnector that implements org.mule.api.Capabilities interface.

Summary

[Expand]

Inherited Constants

From class org.mule.module.mongo.MongoCloudConnector

[Expand]

Inherited Fields

From class org.mule.module.mongo.MongoCloudConnector

private Boolean	autoConnectRetry	This controls whether the system retries automatically on connection errors.
private MongoClient	client
private Integer	connectTimeout	The connection timeout in milliseconds; this is for establishing the socket connections (open).
public Integer	connectionsPerHost	The number of connections allowed per host (the pool size, per host)
private String	database	The database name of the Mongo server
public Boolean	fsync	Sets the fsync value of WriteConcern for the connection.
private String	host	The host of the Mongo server, it can also be a list of comma separated hosts for replicas
public Integer	maxWaitTime	The max wait time for a blocking thread for a connection from the pool in ms.
private int	port	The port of the Mongo server
public Boolean	safe	If the driver sends a getLastError command after every update to ensure it succeeded.
private Boolean	slaveOk	Specifies if the driver is allowed to read from secondaries or slaves.
private Integer	socketTimeout	The socket timeout.
public Integer	threadsAllowedToBlockForConnectionMultiplier	Multiplier for connectionsPerHost for # of threads that can block
public Integer	w	If set, the w value of WriteConcern for the connection is set to this.
public Integer	wtimeout	If set, the wtimeout value of WriteConcern for the connection is set to this.

Public Constructors
	MongoCloudConnectorCapabilitiesAdapter()

Public Methods
boolean	isCapableOf(Capability capability) Returns true if this module implements such capability

[Expand]

Inherited Methods

From class org.mule.module.mongo.MongoCloudConnector

MongoClient	adaptClient(MongoClient client)
static String	bsonListToJson(BasicBSONList input) Convert a BasicBSONList into Json.
void	connect(String username, String password) Method invoked when a `MongoSession` needs to be created.
String	connectionId()
long	countObjects(String collection, DBObject query) Counts the number of objects that match the given query.
long	countObjectsUsingQueryMap(String collection, Map<String, Object> queryAttributes) Counts the number of objects that match the given query.
void	createCollection(String collection, boolean capped, Integer maxObjects, Integer size) Creates a new collection.
DBObject	createFileFromPayload(Object payload, String filename, String contentType, DBObject metadata) Creates a new GridFSFile in the database, saving the given content, filename, contentType, and extraData, and answers it.
void	createIndex(String collection, String field, IndexOrder order) Creates a new index
static Map	dbObjectToMap(DBObject input) Convert a DBObject into Map.
static String	dbobjectToJson(DBObject input) Convert DBObject to Json.
void	disconnect() Method invoked when the `MongoSession` is to be destroyed.
void	dropCollection(String collection) Deletes a collection and all the objects it contains.
void	dropIndex(String collection, String index) Drops an existing index
DBObject	executeCommand(String commandName, String commandValue) Executes a command on the database
boolean	existsCollection(String collection) Answers if a collection exists given its name
Iterable<DBObject>	findFiles(DBObject query) Lists all the files that match the given query
Iterable<DBObject>	findFilesUsingQueryMap(Map<String, Object> queryAttributes) Lists all the files that match the given query
Iterable<DBObject>	findObjects(String collection, DBObject query, List<String> fields, Integer numToSkip, Integer limit) Finds all objects that match a given query.
Iterable<DBObject>	findObjectsUsingQueryMap(String collection, Map<String, Object> queryAttributes, List<String> fields, Integer numToSkip, Integer limit) Finds all objects that match a given query.
DBObject	findOneFile(DBObject query) Answers the first file that matches the given query.
DBObject	findOneFileUsingQueryMap(Map<String, Object> queryAttributes) Answers the first file that matches the given query.
DBObject	findOneObject(String collection, DBObject query, List<String> fields) Finds the first object that matches a given query.
DBObject	findOneObjectUsingQueryMap(String collection, Map<String, Object> queryAttributes, List<String> fields) Finds the first object that matches a given query.
Boolean	getAutoConnectRetry()
Integer	getConnectTimeout()
Integer	getConnectionsPerHost()
String	getDatabase()
InputStream	getFileContent(DBObject query) Answers an inputstream to the contents of the first file that matches the given query.
InputStream	getFileContentUsingQueryMap(Map<String, Object> queryAttributes) Answers an inputstream to the contents of the first file that matches the given queryAttributes.
Boolean	getFsync()
String	getHost()
Integer	getMaxWaitTime()
int	getPort()
Boolean	getSafe()
Boolean	getSlaveOk()
Integer	getSocketTimeout()
Integer	getThreadsAllowedToBlockForConnectionMultiplier()
Integer	getW()
Integer	getWtimeout()
String	insertObject(String collection, DBObject dbObject, WriteConcern writeConcern) Inserts an object in a collection, setting its id if necessary.
String	insertObjectFromMap(String collection, Map<String, Object> elementAttributes, WriteConcern writeConcern) Inserts an object in a collection, setting its id if necessary.
boolean	isConnected()
static DBObject	jsonToDbobject(String input) Convert JSON to DBObject.
Collection<String>	listCollections() Lists names of collections available at this database
Iterable<DBObject>	listFiles(DBObject query) Lists all the files that match the given query, sorting them by filename.
Iterable<DBObject>	listFilesUsingQueryMap(Map<String, Object> queryAttributes) Lists all the files that match the given query, sorting them by filename.
Collection<DBObject>	listIndices(String collection) List existent indices in a collection
Iterable<DBObject>	mapReduceObjects(String collection, String mapFunction, String reduceFunction, String outputCollection) Transforms a collection into a collection of aggregated groups, by applying a supplied element-mapping function to each element, that transforms each one into a key-value pair, grouping the resulting pairs by key, and finally reducing values in each group applying a suppling 'reduce' function.
static String	mongoCollectionToJson(MongoCollection input) Convert a BasicBSONList into Json.
void	removeFiles(DBObject query) Removes all the files that match the given query.
void	removeFilesUsingQueryMap(Map<String, Object> queryAttributes) Removes all the files that match the given query.
void	removeObjects(String collection, DBObject query, WriteConcern writeConcern) Removes all the objects that match the a given optional query.
void	removeUsingQueryMap(String collection, Map<String, Object> queryAttributes, WriteConcern writeConcern) Removes all the objects that match the a given optional query.
void	saveObject(String collection, DBObject element, WriteConcern writeConcern) Inserts or updates an object based on its object _id.
void	saveObjectFromMap(String collection, Map<String, Object> elementAttributes, WriteConcern writeConcern) Inserts or updates an object based on its object _id.
void	setAutoConnectRetry(Boolean autoConnectRetry)
void	setConnectTimeout(Integer connectTimeout)
void	setConnectionsPerHost(Integer connectionsPerHost)
void	setDatabase(String database)
void	setFsync(Boolean fsync)
void	setHost(String host)
void	setMaxWaitTime(Integer maxWaitTime)
void	setPort(int port)
void	setSafe(Boolean safe)
void	setSlaveOk(Boolean slaveOk)
void	setSocketTimeout(Integer socketTimeout)
void	setThreadsAllowedToBlockForConnectionMultiplier(Integer threadsAllowedToBlockForConnectionMultiplier)
void	setW(Integer w)
void	setWtimeout(Integer wtimeout)
void	updateObjects(String collection, DBObject query, DBObject element, boolean upsert, boolean multi, WriteConcern writeConcern) Updates objects that matches the given query.
void	updateObjectsByFunction(String collection, String function, DBObject query, DBObject element, boolean upsert, boolean multi, WriteConcern writeConcern) Update objects using a mongo function
void	updateObjectsByFunctionUsingMap(String collection, String function, Map<String, Object> queryAttributes, Map<String, Object> elementAttributes, boolean upsert, boolean multi, WriteConcern writeConcern) Update objects using a mongo function
void	updateObjectsUsingMap(String collection, Map<String, Object> queryAttributes, Map<String, Object> elementAttributes, boolean upsert, boolean multi, WriteConcern writeConcern) Updates objects that matches the given query.
void	updateObjectsUsingQueryMap(String collection, Map<String, Object> queryAttributes, DBObject element, boolean upsert, boolean multi, WriteConcern writeConcern) Updates objects that matches the given query.

From class java.lang.Object

From interface org.mule.api.Capabilities

Public Constructors

public MongoCloudConnectorCapabilitiesAdapter ()

Public Methods

public boolean isCapableOf (Capability capability)

Returns true if this module implements such capability

Parameters

capability

Classes

MongoCloudConnectorCapabilitiesAdapter

Class Overview

Summary

Public Constructors

public MongoCloudConnectorCapabilitiesAdapter ()

Public Methods

public boolean isCapableOf (Capability capability)

Parameters