---
schema_version: "1"
id: 4be7530ebcfca9f8c44f9a263cf9a142446f746c599da9a59bb0e7b793ca6fc5
title: MongoDB Connector 6.3 Reference
collection: mulesoft
version: current
locale: en-us
portal_url: https://docs.salesforce.com/mulesoft/current/en-us/mongodb-connector/6.3/mongodb-connector-reference.md
canonical_url: https://docs.mulesoft.com/mongodb-connector/6.3/mongodb-connector-reference
source_site: docs.mulesoft.com
content_type: documentation
content_hash: a16fe2702503ec43f6e4c863ea704cd251e77fd410bcc4b6727f98c86d40f7f2
description: MuleSoft Documentation Site
release: "6.3"
latest: false
---
---
product: MongoDB Connector
version: 6.3
---

# MongoDB Connector 6.3 Reference

> For the full documentation index, see: https://docs.mulesoft.com/llms.txt

Anypoint Connector for MongoDB (MongoDB Connector) is a closed-source connector that provides a
connection between the Mule runtime engine (Mule) and third-party software on a MongoDB server.

## Configuration

Default Configuration for MongoDB Connector.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name for this configuration. Connectors reference the configuration with this name.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Connection</strong></p></td><td><div><div><ul><li><p><a href="#config_connection">Connection</a></p></li><li><p><a href="#config_connection-string">Connection String</a></p></li></ul></div></div></td><td><div><div><p>Connection types for this configuration.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Read Concern</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>LOCAL</p></li><li><p>AVAILABLE</p></li><li><p>MAJORITY</p></li><li><p>LINEARIZABLE</p></li><li><p>SNAPSHOT</p></li></ul></div></div></td><td><div><div><p>Enables you to control the consistency and isolation properties of the data read from replica sets and replica set shards.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Read Preference</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>PRIMARY</p></li><li><p>PRIMARY_PREFERED</p></li><li><p>SECONDARY</p></li><li><p>SECONDARY_PREFERRED</p></li><li><p>NEAREST</p></li></ul></div></div></td><td><div><div><p>Specifies the read preferences for this connection.</p></div></div></td><td><div><div><p><code>PRIMARY</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Maximum Staleness Seconds</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies, in seconds, how stale a secondary node on a MongoDB cluster is before the client stops using the secondary node for read operations.</p></div></div></td><td><div><div><p><code>-1</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Read Preference Tags</strong></p></td><td><div><div><p>Array of <a href="#ReadPreferenceTag">Read Preference Tag</a></p></div></div></td><td><div><div><p>If replica set members are associated with tags, you can specify a tag set (array of tag specification documents) in the read preference to target those members.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Encoding</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Specifies the encoding to use in the connector. If unspecified, the default for Mule is used.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Expiration Policy</strong></p></td><td><div><div><p><a href="#ExpirationPolicy">Expiration Policy</a></p></div></div></td><td><div><div><p>Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Acknowledgement</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Level of acknowledgment requested from MongoDB for write operations propagated to the specified number of MongoDB instances. You can specify a number of instances, for example, <code>n&gt;0</code>, or use a value from the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies a time limit, in milliseconds, for <strong>Write Concern Acknowledgement</strong>. The value must be greater than <code>1</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Write Concern Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr></tbody></table>

### Connection Type

Uses a database, a username, and a password for connection.

> [!NOTE] This connector does not validate all possible authentication types.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Servers (host:port)</strong></p></td><td><div><div><p>Array of <a href="#ServerAddress">Server Address</a></p></div></div></td><td><div><div><p>Server in which your MongoDB instance is located. You can specify multiple servers.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Database</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Database name to which you want to connect.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Username</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Username to use for authentication.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Password to use for authentication. If you do not want to use authentication, the password and the username must both be empty.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Replica Set Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the replica set to which to connect. Use this field to connect to a MongoDB cluster.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Authentication Source</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Authentication source.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Compressors</strong></p></td><td><div><div><p>Array of String</p></div></div></td><td><div><div><p>List of compressors to enable network compression for communication between the client and a mongod or mongos instance. If you specify multiple compressors, then the order in which you list the compressors matters. The driver uses the first compressor in the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Zlib Compression Level</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Integer that specifies the compression level if using zlib for network compression. <code>0</code> means no compression. <code>1</code> through <code>9</code> are the compression levels, with <code>1</code> being the lowest compression level, and <code>9</code> being the highest compression level. Higher compression levels take more time to process than lower compression levels.</p></div></div></td><td><div><div><p><code>-1</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Connection Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How long the connector waits before timing out when establishing a connection to the remote service.</p></div></div></td><td><div><div><p><code>30</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Connection Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Connection Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Local Threshold</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Size of the latency window for selecting among multiple suitable MongoDB instances.</p></div></div></td><td><div><div><p><code>15</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Local Threshold Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Local Threshold</strong> field.</p></div></div></td><td><div><div><p><code>MILLISECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Server Selection Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How long to block for server selection before throwing an exception.</p></div></div></td><td><div><div><p><code>30</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Server Selection Timeout Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Server Selection Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Socket Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Socket timeout. Used for I/O socket read and write operations. Set this field to <code>0</code> if you do not want socket read and write operations to time out.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Socket Timeout Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Socket Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Retry Writes</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Enable retryable writes.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Authentication Mechanism</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>PLAIN</p></li><li><p>SCRAM_SHA_1</p></li><li><p>SCRAM_SHA_256</p></li></ul></div></div></td><td><div><div><p>Authentication mechanism used for this connection.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Tls Context</strong></p></td><td><div><div><p><a href="#Tls">Tls</a></p></div></div></td><td><div><div><p>Configures TLS. If using the HTTPS protocol, you must configure TLS.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Min Connection Pool Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Minimum size for the connection pool.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Connection Pool Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum size for the connection pool.</p></div></div></td><td><div><div><p><code>100</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Wait Queue Time</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum wait queue time for the connection pool.</p></div></div></td><td><div><div><p><code>120</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Wait Queue Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Max Wait Queue Time</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Connection Life Time</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum connection lifetime for the connection pool.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Connection Life Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Max Connection Life Time</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Connection Idle Time</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum connection idle time for the connection pool.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Connection Idle Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Max Connection Idle Time</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection</strong></p></td><td><div><div><p><a href="#Reconnection">Reconnection</a></p></div></div></td><td><div><div><p>Configures a reconnection strategy to use when a connector operation fails to connect to an external server.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Connection String Connection Type

Uses a connection string for connection.

> [!NOTE] This connector does not validate all possible authentication types.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Connection String</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>URI that describes the hosts to use and their options.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Tls Context</strong></p></td><td><div><div><p><a href="#Tls">Tls</a></p></div></div></td><td><div><div><p>Configures TLS. If using the HTTPS protocol, you must configure TLS.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection</strong></p></td><td><div><div><p><a href="#Reconnection">Reconnection</a></p></div></div></td><td><div><div><p>Configures a reconnection strategy to use when a connector operation fails to connect to an external server.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

## Sources

- [On Object Listener](#object-listener)

### On Object Listener

`<mongo:object-listener>`

Source for object events.

> [!NOTE] This source (listener) uses Object Store to save watermarks. You might experience
> limitations that are specific to the Object Store implementation you are using (Object Store for
> CloudHub deployments or Object Store for on-premises deployments), so configure Object Store to
> suit your needs.  
> For more information, see
> [The Different Types of Object Stores Explained](https://help.salesforce.com/s/articleView?id=001123185&type=1).

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Collection that is watched to detect the matching documents.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Watermark Field</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Field that is queried to detect the objects that match the trigger condition.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Primary Node Only</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Determines whether to execute this source on only the primary node when running Mule instances in a cluster.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Scheduling Strategy</strong></p></td><td><div><div><p>scheduling-strategy</p></div></div></td><td><div><div><p>Configures the scheduler that triggers the polling.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-stream">Repeatable In Memory Stream</a></p></li><li><p><a href="#repeatable-file-store-stream">Repeatable File Store Stream</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Redelivery Policy</strong></p></td><td><div><div><p><a href="#RedeliveryPolicy">Redelivery Policy</a></p></div></div></td><td><div><div><p>Defines a policy for processing the redelivery of the same message.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

## Operations

- [Add User](#addUser)

- [Collection Exists](#collectionExists)

- [Count Documents](#countDocuments)

- [Create Collection](#createCollection)

- [Create File](#createFile)

- [Create Index](#createIndex)

- [Drop Collection](#dropCollection)

- [Drop Database](#dropDatabase)

- [Drop Index](#dropIndex)

- [Dump](#dump)

- [Execute Command](#executeCommand)

- [Find Documents](#findDocuments)

- [Find Files](#findFiles)

- [Get File Content](#getFileContent)

- [Insert Document](#insertDocument)

- [Insert Documents](#insertDocuments)

- [List Collections](#listCollections)

- [List Indexes](#listIndexes)

- [Map Reduce](#mapReduce)

- [Remove Documents](#removeDocuments)

- [Remove Files](#removeFiles)

- [Restore From Directory](#restoreFromDirectory)

- [Restore From File](#restoreFromFile)

- [Update Documents](#updateDocuments)

### Add User

`<mongo:add-user>`

Adds a new user for this database.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Username</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the user.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Password to use for authentication.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Collection Exists

`<mongo:collection-exists>`

Returns `true` if the specified collection exists.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Boolean</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Count Documents

`<mongo:count-documents>`

Counts the number of documents that match the given query. If no query is passed, the operation
returns the number of elements in the collection.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Target collection.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Query</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Query for counting documents. Only documents matching the query are counted. If unspecified, all documents are counted. Values can be <code>{"field1": "value1"}</code> or can contain operators <code>{"field1": {$gte: 1, $lt: 10}}</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Acknowledgement</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Level of acknowledgment requested from MongoDB for write operations propagated to the specified number of MongoDB instances. You can specify a number of instances, for example, <code>n&gt;0</code>, or use a value from the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies a time limit, in milliseconds, for <strong>Write Concern Acknowledgement</strong>. The value must be greater than <code>1</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Write Concern Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Number</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Create Collection

`<mongo:create-collection>`

Creates a new collection. If the collection already exists, a `MongoException` is thrown.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection to create.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Max Objects</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum number of documents the new collection contains.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Collection Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum size of the new collection.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Collection Size Data Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><div><div><p>Data unit of the <strong>Collection Size</strong> field.</p></div></div></td><td><div><div><p><code>BYTE</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Create File

`<mongo:create-file>`

Creates a new file in the database, saving the specified content, file name, content type, and extra
data.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Content</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Content of the new file. This content is an InputStream.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Filename</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the new file.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Metadata</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>JSON object that holds information to store.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-stream">Repeatable In Memory Stream</a></p></li><li><p><a href="#repeatable-file-store-stream">Repeatable File Store Stream</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Create Index

`<mongo:create-index>`

Creates a new index.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection in which the index is created.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Field Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the field that is indexed.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Sort Order</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>ASC</p></li><li><p>DESC</p></li></ul></div></div></td><td><div><div><p>Indexing order.</p></div></div></td><td><div><div><p><code>ASC</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>String</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Drop Collection

`<mongo:drop-collection>`

Deletes a collection and all the objects it contains. If the collection does not exist, the
operation throws a `NOT_FOUND` error.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection to drop.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Drop Database

`<mongo:drop-database>`

Drop the current database.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Database Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the database to drop.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Drop Index

`<mongo:drop-index>`

Drops an existing index.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Index Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the index to drop.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Dump

`<mongo:dump>`

Executes a dump of the database to the specified output directory. If no output directory is
provided, the default /dump directory is used.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Output Directory</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Output directory in which dump files are created.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Output Name Prefix</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Output file name prefix. If unspecified, the database name is used.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Oplog</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Point in time backup (requires an oplog).</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Operation Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum wait time for the dump.</p></div></div></td><td><div><div><p><code>60</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Operation Timeout Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Operation Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Array of String</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Execute Command

`<mongo:execute-command>`

Executes a command on the database.

The **Execute Command** operation results are not paginated.

If an execution returns a cursor reference, use the `getMore` command to retrieve the next page of
results. Refer to [Additional Configuration Information](https://docs.mulesoft.com/mongodb-connector/6.3/mongodb-connector-additional-configuration)
for more details.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Command</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Command to execute on the database as a document.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-stream">Repeatable In Memory Stream</a></p></li><li><p><a href="#repeatable-file-store-stream">Repeatable File Store Stream</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Find Documents

`<mongo:find-documents>`

Finds all documents that match a given query. If no query is specified, all documents of the
collection are retrieved. If no fields object is specified, all fields are retrieved.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Query</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Query for finding documents. If unspecified, all documents are retrieved. Values can be <code>{"field1": "value1"}</code> or can contain operators <code>{"field1": {$gte: 1, $lt: 10}}</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Sort By</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Indicates the document used to sort the results. Use <code>[{"yourField":"ASC"}]</code> to sort by ascending, or <code>[{"yourField":"DESC"}]</code> to sort by descending.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Page Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Size of the documents of each page to return.</p></div></div></td><td><div><div><p><code>100</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Limit</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Limit of the documents to return.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Acknowledgement</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Level of acknowledgment requested from MongoDB for write operations propagated to the specified number of MongoDB instances. You can specify a number of instances, for example, <code>n&gt;0</code>, or use a value from the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies a time limit, in milliseconds, for <strong>Write Concern Acknowledgement</strong>. The value must be greater than <code>1</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Write Concern Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-iterable">Repeatable In Memory Iterable</a></p></li><li><p><a href="#repeatable-file-store-iterable">Repeatable File Store Iterable</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Collection name.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Fields</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Comma-separated list of fields to return from each document. To return all fields, type a single comma character.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Array of Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Find Files

`<mongo:find-files>`

Lists all files that match the given query.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Query</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Query for listing all files. Values can be <code>{"field1": "value1"}</code> or can contain operators <code>{"field1": {$gte: 1, $lt: 10}}</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Sort</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Enables you to sort the result list. A file is sorted by file ID or upload date.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Array of Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT-FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Get File Content

`<mongo:get-file-content>`

Gets an InputStream to the content of the file specified by **File Id**.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>File Id</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Mandatory file ID.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p><strong>Type</strong></p></td><td><div><div><p>Any</p></div></div></td></tr><tr><td><p><strong>Attributes Type</strong></p></td><td><div><div><p>Binary</p></div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Insert Document

`<mongo:insert-document>`

Inserts a document in a collection. If you do not use the `id` field to specify an object, MongoDB
automatically generates an ID.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection in which to insert the given document.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Document</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Document to insert.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Acknowledgement</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Level of acknowledgment requested from MongoDB for write operations propagated to the specified number of MongoDB instances. You can specify a number of instances, for example, <code>n&gt;0</code>, or use a value from the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies a time limit, in milliseconds, for <strong>Write Concern Acknowledgement</strong>. The value must be greater than <code>1</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Write Concern Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-stream">Repeatable In Memory Stream</a></p></li><li><p><a href="#repeatable-file-store-stream">Repeatable File Store Stream</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Insert Documents

`<mongo:insert-documents>`

Inserts a document in a collection. If you don’t use the `id` field to specify an object, MongoDB
automatically generates an ID.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection in which to insert the given document.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Documents</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>List of the documents to insert.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Ordered</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Indicates whether the list of documents are executed in order. If set to <code>true</code> and an error occurs during the processing of one of the write operations, MongoDB returns without processing any remaining write operations in the list.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Acknowledgement</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Level of acknowledgment requested from MongoDB for write operations propagated to the specified number of MongoDB instances. You can specify a number of instances, for example, <code>n&gt;0</code>, or use a value from the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies a time limit, in milliseconds, for <strong>Write Concern Acknowledgement</strong>. The value must be greater than <code>1</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Write Concern Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p><a href="#BulkOperationResult">Bulk Operation Result</a></p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### List Collections

`<mongo:list-collections>`

Lists names of collections available on this database.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Array of String</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### List Indexes

`<mongo:list-indexes>`

Lists existent indexes in a collection.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Array of <a href="#Index">Index</a></p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Map Reduce

`<mongo:map-reduce>`

Transforms a collection into a collection of aggregated groups, as follows:

1.  Applies a supplied element-mapping function to each element, which transforms each element into
    a key-value pair.

2.  Groups the resulting pairs by key.

3.  Reduces values in each group by applying a supplied 'reduce' function coded in JavaScript.

Refer to the MongoDB documentation for more information.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection to map and reduce.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Mapping Function</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>JavaScript-encoded mapping function.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Reduce Function</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>JavaScript-encoded reducing function.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Output Collection</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the output collection to which to write the results. This replaces an existing collection, if any exists. This field is mandatory if the resulting objects are larger than 16 MB. If <strong>Output Collection</strong> is unspecified, the computation is performed in-memory and is not persisted.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-stream">Repeatable In Memory Stream</a></p></li><li><p><a href="#repeatable-file-store-stream">Repeatable File Store Stream</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Binary</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Remove Documents

`<mongo:remove-documents>`

Removes all the documents that match the specified query. If a query is not specified, all documents
are removed. It is more efficient to drop a connection and re-create it than to use this operation.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Collection for which to remove elements.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Query</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Query for detecting the elements to delete. Values can be <code>{"field1": "value1"}</code> or can contain operators <code>{"field1": {$gte: 1, $lt: 10}}</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Number</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Remove Files

`<mongo:remove-files>`

Removes the file that matches the given file ID. If no file ID is specified, all files are removed.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>File Id</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>ID of the file to delete.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Restore From Directory

`<mongo:restore-from-directory>`

Takes the output from the **Dump** operation, restores the output, and generates indexes. This
operation inserts records only when the IDs do not already exist in the database.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Input Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Input path of the dump files. This path must be a directory.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Drop Collections</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Indicates whether to drop existing collections before performing the restore.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Oplog Replay</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Replay oplog used for point-in-time restore.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Restore From File

`<mongo:restore-from-file>`

Restores a single .bson file or a zip file.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection to restore.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Input</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>InputStream that points to the dump file. It can be a .bson file or a zip file.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Drop Collection</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Indicates whether to drop existing collections before performing the restore.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

### Update Documents

`<mongo:update-documents>`

Updates documents that match the specified query. If a query is not specified, all documents are
retrieved. If the multi parameter is set to `false`, only the first document matching the query is
updated. Otherwise, all documents matching the query are updated.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Name</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Configuration</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the configuration to use.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Collection Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the collection to update.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Query</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Query for detecting the element to update. Values can be <code>{"field1": "value1"}</code> or can contain operators <code>{"field1": {$gte: 1, $lt: 10}}</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Content To Update</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Object to replace the document that matches the query.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Multiple Update</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Indicates whether only the first document matching the query is updated.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Upsert</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>If set to <code>true</code>, creates a new document when no document matches the query criteria. The default value is <code>false</code>, which does not insert a new document when no match is found.</p></div></div></td><td><div><div><p><code>false</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Acknowledgement</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Level of acknowledgment requested from MongoDB for write operations propagated to the specified number of MongoDB instances. You can specify a number of instances, for example, <code>n&gt;0</code>, or use a value from the list.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Specifies a time limit, in milliseconds, for <strong>Write Concern Acknowledgement</strong>. The value must be greater than <code>1</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Write Concern Timeout Timeunit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Write Concern Timeout</strong> field.</p></div></div></td><td><div><div><p><code>SECONDS</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Streaming Strategy</strong></p></td><td><div><div><ul><li><p><a href="#repeatable-in-memory-stream">Repeatable In Memory Stream</a></p></li><li><p><a href="#repeatable-file-store-stream">Repeatable File Store Stream</a></p></li></ul></div></div></td><td><div><div><p>Configures how Mule processes streams. Repeatable streams are the default behavior.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Variable</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the variable that stores the operation’s output.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Target Value</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Expression that evaluates the operation’s output. The expression outcome is stored in the target variable.</p></div></div></td><td><div><div><p><code>#[payload]</code></p></div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Retry strategy in case of connectivity errors.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

#### Output

<table><colgroup><col> <col></colgroup><tbody><tr><td><p>Type</p></td><td><p>Any</p></td></tr></tbody></table>

#### Associated Configurations

- [Configuration](#config)

#### Throws

- MONGO:DUPLICATE\_ERROR

- MONGO:CONSISTENCY\_ERROR

- MONGO:RETRY\_EXHAUSTED

- MONGO:NOT\_FOUND

- MONGO:PERMISSIONS\_DENIED

- MONGO:TIMEOUT

- MONGO:INVALID\_INPUT

- MONGO:CONNECTIVITY

## Object Types

- [Bulk Item](#BulkItem)

- [Bulk Operation Result](#BulkOperationResult)

- [Crl File](#crl-file)

- [Custom Ocsp Responder](#custom-ocsp-responder)

- [Expiration Policy](#ExpirationPolicy)

- [Index](#Index)

- [Key Store](#KeyStore)

- [Read Preference Tag](#ReadPreferenceTag)

- [Reconnect](#reconnect)

- [Reconnect Forever](#reconnect-forever)

- [Reconnection](#Reconnection)

- [Redelivery Policy](#RedeliveryPolicy)

- [Repeatable File Store Iterable](#repeatable-file-store-iterable)

- [Repeatable File Store Stream](#repeatable-file-store-stream)

- [Repeatable In Memory Iterable](#repeatable-in-memory-iterable)

- [Repeatable In Memory Stream](#repeatable-in-memory-stream)

- [Server Address](#ServerAddress)

- [Standard Revocation Check](#standard-revocation-check)

- [Tls](#Tls)

- [Trust Store](#TrustStore)

### Bulk Item

Bulk item type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Exception</strong></p></td><td><div><div><p>Any</p></div></div></td><td><div><div><p>Exception.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Id</strong></p></td><td><div><div><p>Any</p></div></div></td><td><div><div><p>ID.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Message</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Message.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Payload</strong></p></td><td><div><div><p>Binary</p></div></div></td><td><div><div><p>Payload.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Status Code</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Status code.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Successful</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Indicates success.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Bulk Operation Result

Bulk operation result type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Id</strong></p></td><td><div><div><p>Any</p></div></div></td><td><div><div><p>ID.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Items</strong></p></td><td><div><div><p>Array of <a href="#BulkItem">Bulk Item</a></p></div></div></td><td><div><div><p>Array of items.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Successful</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Indicates success.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Crl File

Specifies the location of the certification revocation list (CRL) file.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Path to the CRL file.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Custom Ocsp Responder

Configures a custom OCSP responder for certification revocation checks.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Url</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>URL of the OCSP responder.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Cert Alias</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Expiration Policy

Configures an expiration policy strategy.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Max Idle Time</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Time Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>NANOSECONDS</p></li><li><p>MICROSECONDS</p></li><li><p>MILLISECONDS</p></li><li><p>SECONDS</p></li><li><p>MINUTES</p></li><li><p>HOURS</p></li><li><p>DAYS</p></li></ul></div></div></td><td><div><div><p>Time unit for the <strong>Max Idle Time</strong> field.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Index

Index type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Field Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Field name.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Name</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Name of the index.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Order</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>ASC</p></li><li><p>DESC</p></li></ul></div></div></td><td><div><div><p>Order of the index.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Key Store

Configures the keystore for the TLS protocol. The keystore you generate contains a private key and a
public certificate.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Path to the keystore. Mule resolves the path relative to the current classpath and file system.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Type</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Type of keystore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Alias</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Key Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Password used to protect the private key.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Password used to protect the keystore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Algorithm</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Encryption algorithm that the keystore uses.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Read Preference Tag

Read preference tag type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Name Value</strong></p></td><td><div><div><p>Object</p></div></div></td><td><div><div><p>Name value.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr></tbody></table>

### Reconnect

Configures a standard reconnection strategy, which specifies how often to reconnect and how many
reconnection attempts the connector source or operation can make.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Frequency</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How often to attempt to reconnect, in milliseconds.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Blocking</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>If <code>false</code>, the reconnection strategy runs in a separate, non-blocking thread.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Count</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How many reconnection attempts the Mule app can make.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Reconnect Forever

Configures a forever reconnection strategy by which the connector source or operation attempts to
reconnect at a specified frequency for as long as the Mule app runs.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Frequency</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>How often to attempt to reconnect, in milliseconds.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Reconnection

Configures a reconnection strategy for an operation.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Fails Deployment</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>What to do if, when an app is deployed, a connectivity test does not pass after exhausting the associated reconnection strategy:</p></div><div><ul><li><p><code>true</code></p><div><p>Allow the deployment to fail.</p></div></li><li><p><code>false</code></p><div><p>Ignore the results of the connectivity test.</p></div></li></ul></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Reconnection Strategy</strong></p></td><td><div><div><ul><li><p><a href="#reconnect">Reconnect</a></p></li><li><p><a href="#reconnect-forever">Reconnect Forever</a></p></li></ul></div></div></td><td><div><div><p>Reconnection strategy to use.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Redelivery Policy

Configures the redelivery policy for executing requests that generate errors. You can add a
redelivery policy to any source in a flow.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Max Redelivery Count</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum number of times that a redelivered request can be processed unsuccessfully before returning a <code>REDELIVERY_EXHAUSTED</code> error.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Message Digest Algorithm</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Secure hashing algorithm to use if the <strong>Use Secure Hash</strong> field is <code>true</code>. If the payload of the message is a Java object, Mule ignores this value and returns the value that the payload’s <code>hashCode()</code> returned.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Id Expression</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>One or more expressions that determine if a message is redelivered. This property can be set only if the <strong>Use Secure Hash</strong> field is <code>false</code>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Object Store</strong></p></td><td><div><div><p>ObjectStore</p></div></div></td><td><div><div><p>Configures the object store that stores the redelivery counter for each message.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Repeatable File Store Iterable

Repeatable file store iterable type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>In Memory Objects</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum amount of instances to keep in memory. If more than that is required, content on the disk is buffered.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><div><div><p>Unit for the <strong>In Memory Size</strong> field.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Repeatable File Store Stream

Configures the repeatable file-store streaming strategy by which Mule keeps a portion of the stream
content in memory. If the stream content is larger than the configured buffer size, Mule backs up
the buffer’s content to disk and then clears the memory.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>In Memory Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:</p></div><div><ul><li><p>Configure a larger buffer size to avoid the number of times Mule needs to write the buffer on disk. This increases performance, but it also limits the number of concurrent requests your application can process, because it requires additional memory.</p></li><li><p>Configure a smaller buffer size to decrease memory load at the expense of response time.</p></li></ul></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><div><div><p>Unit for the <strong>In Memory Size</strong> field.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Repeatable In Memory Iterable

Repeatable in memory iterable type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Initial Buffer Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Amount of instances to initially keep in memory to consume the stream and provide random access to it. If the stream contains more data than can fit into this buffer, then the buffer expands according to the <strong>Buffer Size Increment</strong> attribute, with an upper limit of <strong>Max In Memory Size</strong>. Default value is 100 instances.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Size Increment</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>This is by how much the buffer size expands if it exceeds its initial size. Setting a value of <code>0</code> or lower means that the buffer must not expand, meaning that a <code>STREAM_MAXIMUM_SIZE_EXCEEDED</code> error is raised when the buffer gets full. Default value is 100 instances.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Buffer Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Maximum amount of memory to use. If more than that is used, a <code>STREAM_MAXIMUM_SIZE_EXCEEDED</code> error is raised. A value lower than or equal to <code>0</code> means no limit.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Repeatable In Memory Stream

Configures the in-memory streaming strategy by which the request fails if the data exceeds the MAX
buffer size. Always run performance tests to find the optimal buffer size for your specific use
case.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Initial Buffer Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by <strong>Buffer Size Increment</strong>, with an upper limit of <strong>Max In Memory Size value</strong>.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Size Increment</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Amount by which the buffer size expands if it exceeds its initial size. Setting a value of <code>0</code> or lower specifies that the buffer can’t expand.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Max Buffer Size</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>The maximum amount of memory to use. If more than that is used then a <code>STREAM_MAXIMUM_SIZE_EXCEEDED</code> error is raised. A value lower than or equal to zero means no limit.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Buffer Unit</strong></p></td><td><div><div><p>Enumeration, one of:</p></div><div><ul><li><p>BYTE</p></li><li><p>KB</p></li><li><p>MB</p></li><li><p>GB</p></li></ul></div></div></td><td><div><div><p>Unit for the <strong>Initial Buffer Size</strong>, <strong>Buffer Size Increment</strong>, and <strong>Buffer Unit</strong> fields.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Server Address

Server address type.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Host</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Host to which you want to connect.</p></div></div></td><td><div></div></td><td><div><div><p>x</p></div></div></td></tr><tr><td><p><strong>Port</strong></p></td><td><div><div><p>Number</p></div></div></td><td><div><div><p>Port of the host to which you want to connect.</p></div></div></td><td><div><div><p><code>27017</code></p></div></div></td><td><div></div></td></tr></tbody></table>

### Standard Revocation Check

Configures standard revocation checks for TLS certificates.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Only End Entities</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Which elements to verify in the certificate chain:</p></div><div><ul><li><p><code>true</code></p><div><p>Verify only the last element in the certificate chain.</p></div></li><li><p><code>false</code></p><div><p>Verify all elements in the certificate chain.</p></div></li></ul></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Prefer Crls</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>How to check certificate validity:</p></div><div><ul><li><p><code>true</code></p><div><p>Check the Certification Revocation List (CRL) for certificate validity.</p></div></li><li><p><code>false</code></p><div><p>Use the Online Certificate Status Protocol (OCSP) to check certificate validity.</p></div></li></ul></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>No Fallback</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>Whether to use the secondary method to check certificate validity:</p></div><div><ul><li><p><code>true</code></p><div><p>Use the method that wasn’t specified in the <strong>Prefer Crls</strong> field (the secondary method) to check certificate validity.</p></div></li><li><p><code>false</code></p><div><p>Do not use the secondary method to check certificate validity.</p></div></li></ul></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Soft Fail</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>What to do if the revocation server can’t be reached or is busy:</p></div><div><ul><li><p><code>true</code></p><div><p>Avoid verification failure.</p></div></li><li><p><code>false</code></p><div><p>Allow the verification to fail.</p></div></li></ul></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Tls

Configures TLS to provide secure communications for the Mule app.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Enabled Protocols</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Comma-separated list of protocols enabled for this context.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Enabled Cipher Suites</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Comma-separated list of cipher suites enabled for this context.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Trust Store</strong></p></td><td><div><div><p><a href="#TrustStore">Trust Store</a></p></div></div></td><td><div><div><p>Configures the TLS truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Key Store</strong></p></td><td><div><div><p><a href="#KeyStore">Key Store</a></p></div></div></td><td><div><div><p>Configures the TLS keystore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Revocation Check</strong></p></td><td><div><div><ul><li><p><a href="#standard-revocation-check">Standard Revocation Check</a></p></li><li><p><a href="#custom-ocsp-responder">Custom Ocsp Responder</a></p></li><li><p><a href="#crl-file">Crl File</a></p></li></ul></div></div></td><td><div><div><p>Configures a revocation checking mechanism.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

### Trust Store

Configures the truststore for TLS.

<table><colgroup><col> <col> <col> <col> <col></colgroup><thead><tr><th>Field</th><th>Type</th><th>Description</th><th>Default Value</th><th>Required</th></tr></thead><tbody><tr><td><p><strong>Path</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Path to the truststore. Mule resolves the path relative to the current classpath and file system.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Password</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Password used to protect the truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Type</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Type of truststore.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Algorithm</strong></p></td><td><div><div><p>String</p></div></div></td><td><div><div><p>Encryption algorithm that the truststore uses.</p></div></div></td><td><div></div></td><td><div></div></td></tr><tr><td><p><strong>Insecure</strong></p></td><td><div><div><p>Boolean</p></div></div></td><td><div><div><p>If <code>true</code>, Mule stops performing certificate validations. Setting this to <code>true</code> can make connections vulnerable to attacks.</p></div></div></td><td><div></div></td><td><div></div></td></tr></tbody></table>

## System Properties

You can configure this system property for the MongoDB Connector:

<table><colgroup><col> <col> <col></colgroup><thead><tr><th>Property</th><th>Default</th><th>Description</th></tr></thead><tbody><tr><td><p><strong><code>com.mulesoft.connector.mongo.skipIsoCoercionUnderOperatorKeys</code></strong></p></td><td><div><div><p><code>false</code></p></div></div></td><td><div><div><p>When set to <code>true</code>, ISO-8601 strings nested under MongoDB query operator keys (keys prefixed with <code>$</code>, such as <code>$match</code>, <code>$and</code>, <code>$or</code>, <code>$elemMatch</code>, <code>$expr</code>, and <code>$lte</code>) are passed through verbatim as strings instead of being auto-coerced to BSON Date values. Use this property only if you query String-typed date fields through operator expressions and the queries return empty results unexpectedly.</p></div></div></td></tr></tbody></table>

> [!NOTE] This system property applies JVM-wide to all MongoDB Connector configurations and
> operations, and takes effect only after a Mule app restart.
>
> If your app relies on ISO-8601 auto-coercion for fields that store genuine BSON Date values, use
> Extended JSON notation (`{"$date": "…​"}`) or DataWeave date types instead of enabling this
> property.

## See Also

- [Introduction to Anypoint Connectors](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors)

- [Salesforce Help](https://help.salesforce.com)