You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2025/02/16 09:03:00 UTC
(camel) 01/01: CAMEL-21735: camel-mongodb: If explicit configured with host to use, then do not use autowited client (which CEQ may provide by default, so you connect to the wrong host)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch mongo
in repository https://gitbox.apache.org/repos/asf/camel.git
commit fa45317186ba6b0e34fa4dadb707d5f8d3df82c5
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sun Feb 16 10:02:35 2025 +0100
CAMEL-21735: camel-mongodb: If explicit configured with host to use, then do not use autowited client (which CEQ may provide by default, so you connect to the wrong host)
---
.../apache/camel/catalog/components/mongodb.json | 92 ++--
.../apache/camel/component/mongodb/mongodb.json | 92 ++--
.../camel/component/mongodb/MongoDbComponent.java | 2 -
.../camel/component/mongodb/MongoDbEndpoint.java | 135 +-----
.../dsl/MongoDbEndpointBuilderFactory.java | 539 +++++++++++----------
5 files changed, 386 insertions(+), 474 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/mongodb.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/mongodb.json
index 80793d32e1a..cc4210837ff 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/mongodb.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/mongodb.json
@@ -68,51 +68,51 @@
"mongoConnection": { "index": 7, "kind": "parameter", "displayName": "Mongo Connection", "group": "common", "label": "", "required": false, "type": "object", "javaType": "com.mongodb.client.MongoClient", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the connection bean used as a client for connecting to a database." },
"operation": { "index": 8, "kind": "parameter", "displayName": "Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.mongodb.MongoDbOperation", "enum": [ "findById", "findOneAndDelete", "findOneAndReplace", "findOneAndUpdate", "findOneByQuery", "findAll", "findDistinct", "insert", "save", "update", "remove", "bulkWrite", "aggregate", "getDbStats", "getColStats", "count", "command" ], "deprecated": false, "autowired": [...]
"outputType": { "index": 9, "kind": "parameter", "displayName": "Output Type", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "org.apache.camel.component.mongodb.MongoDbOutputType", "enum": [ "DocumentList", "Document", "MongoIterable" ], "deprecated": false, "autowired": false, "secret": false, "description": "Convert the output of the producer to the selected type: DocumentList Document or MongoIterable. DocumentList or MongoIterable applies [...]
- "consumerType": { "index": 10, "kind": "parameter", "displayName": "Consumer Type", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Consumer type." },
- "bridgeErrorHandler": { "index": 11, "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming [...]
- "exceptionHandler": { "index": 12, "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By de [...]
- "exchangePattern": { "index": 13, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "lazyStartProducer": { "index": 14, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a produ [...]
- "appName": { "index": 15, "kind": "parameter", "displayName": "App Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the logical name of the application. The application name may be used by the client to identify the application to the server, for use in server logs, slow query logs, and profile collection. Default: null" },
- "compressors": { "index": 16, "kind": "parameter", "displayName": "Compressors", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies one or more compression algorithms that the driver will attempt to use to compress requests sent to the connected MongoDB instance. Possible values include: zlib, snappy, and zstd. Default: null" },
- "connectTimeoutMS": { "index": 17, "kind": "parameter", "displayName": "Connect Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10000", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver waits for a connection to open before timing out. A value of 0 instructs the driver to never time out while wait [...]
- "cursorRegenerationDelay": { "index": 18, "kind": "parameter", "displayName": "Cursor Regeneration Delay", "group": "advanced", "label": "advanced", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1000", "description": "MongoDB tailable cursors will block until new data arrives. If no new data is inserted, after some time the cursor will be automatically freed and closed by the MongoDB server. The c [...]
- "directConnection": { "index": 19, "kind": "parameter", "displayName": "Direct Connection", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver must connect to the host directly. Default: false" },
- "dynamicity": { "index": 20, "kind": "parameter", "displayName": "Dynamicity", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether this endpoint will attempt to dynamically resolve the target database and collection from the incoming Exchange properties. Can be used to override at runtime the database and collection specified [...]
- "heartbeatFrequencyMS": { "index": 21, "kind": "parameter", "displayName": "Heartbeat Frequency MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "heartbeatFrequencyMS controls when the driver checks the state of the MongoDB deployment. Specify the interval (in milliseconds) between checks, counted from the end of the previous check until the be [...]
- "loadBalanced": { "index": 22, "kind": "parameter", "displayName": "Load Balanced", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If true the driver will assume that it's connecting to MongoDB through a load balancer." },
- "localThresholdMS": { "index": 23, "kind": "parameter", "displayName": "Local Threshold MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "15", "description": "The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances. Default: 15 milliseconds." },
- "maxConnecting": { "index": 24, "kind": "parameter", "displayName": "Max Connecting", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2", "description": "Specifies the maximum number of connections a pool may be establishing concurrently. Default: 2" },
- "maxIdleTimeMS": { "index": 25, "kind": "parameter", "displayName": "Max Idle Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will allow a pooled connection to idle before closing the connection. A value of 0 indicates that there is no upper bound [...]
- "maxLifeTimeMS": { "index": 26, "kind": "parameter", "displayName": "Max Life Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will continue to use a pooled connection before closing the connection. A value of 0 indicates that there is no upper bou [...]
- "maxPoolSize": { "index": 27, "kind": "parameter", "displayName": "Max Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100", "description": "The maximum number of connections in the connection pool. The default value is 100." },
- "maxStalenessSeconds": { "index": 28, "kind": "parameter", "displayName": "Max Staleness Seconds", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "Specifies, in seconds, how stale a secondary can be before the driver stops communicating with that secondary. The minimum value is either 90 seconds or the heartbeat frequency plu [...]
- "minPoolSize": { "index": 29, "kind": "parameter", "displayName": "Min Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the minimum number of connections that must exist at any moment in a single connection pool. Default: 0" },
- "readPreference": { "index": 30, "kind": "parameter", "displayName": "Read Preference", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "PRIMARY", "PRIMARY_PREFERRED", "SECONDARY", "SECONDARY_PREFERRED", "NEAREST" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "PRIMARY", "description": "Configure how MongoDB clients route read operations to the members of a replica set. Possible val [...]
- "readPreferenceTags": { "index": 31, "kind": "parameter", "displayName": "Read Preference Tags", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "A representation of a tag set as a comma-separated list of colon-separated key-value pairs, e.g. dc:ny,rack:1. Spaces are stripped from the beginning and end of all keys and values. To specify a list of tag [...]
- "replicaSet": { "index": 32, "kind": "parameter", "displayName": "Replica Set", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies that the connection string provided includes multiple hosts. When specified, the driver attempts to find all members of that set." },
- "retryReads": { "index": 33, "kind": "parameter", "displayName": "Retry Reads", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported read operations if they fail due to a network error. Default: true" },
- "retryWrites": { "index": 34, "kind": "parameter", "displayName": "Retry Writes", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported write operations if they fail due to a network error. Default: true" },
- "serverSelectionTimeoutMS": { "index": 35, "kind": "parameter", "displayName": "Server Selection Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30000", "description": "Specifies how long (in milliseconds) to block for server selection before throwing an exception. Default: 30,000 milliseconds." },
- "socketTimeoutMS": { "index": 36, "kind": "parameter", "displayName": "Socket Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will wait to send or receive a request before timing out. A value of 0 instructs the driver to never time out while wa [...]
- "srvMaxHosts": { "index": 37, "kind": "parameter", "displayName": "Srv Max Hosts", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "The maximum number of hosts from the SRV record to connect to." },
- "srvServiceName": { "index": 38, "kind": "parameter", "displayName": "Srv Service Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "mongodb", "description": "Specifies the service name of the SRV resource recordsthe driver retrieves to construct your seed list. You must use the DNS Seed List Connection Format in your connection URI to use this [...]
- "tls": { "index": 39, "kind": "parameter", "displayName": "Tls", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that all communication with MongoDB instances should use TLS. Supersedes the ssl option. Default: false" },
- "tlsAllowInvalidHostnames": { "index": 40, "kind": "parameter", "displayName": "Tls Allow Invalid Hostnames", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver should allow invalid hostnames in the certificate for TLS connections. Supersedes sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by setti [...]
- "waitQueueTimeoutMS": { "index": 41, "kind": "parameter", "displayName": "Wait Queue Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "120000", "description": "Specifies the maximum amount of time, in milliseconds that a thread may wait for a connection to become available. Default: 120000 (120 seconds)" },
- "writeConcern": { "index": 42, "kind": "parameter", "displayName": "Write Concern", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "ACKNOWLEDGED", "W1", "W2", "W3", "UNACKNOWLEDGED", "JOURNALED", "MAJORITY" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "ACKNOWLEDGED", "description": "Configure the connection bean with the level of acknowledgment requested from MongoDB for write op [...]
- "writeResultAsHeader": { "index": 43, "kind": "parameter", "displayName": "Write Result As Header", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "In write operations, it determines whether instead of returning WriteResult as the body of the OUT message, we transfer the IN message to the OUT and attach the WriteResult as a header." },
- "zlibCompressionLevel": { "index": 44, "kind": "parameter", "displayName": "Zlib Compression Level", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies the degree of compression that Zlib should use to decrease the size of requests to the connected MongoDB instance. The level can range from -1 to 9, with lower values compressing faster (but [...]
- "fullDocument": { "index": 45, "kind": "parameter", "displayName": "Full Document", "group": "changeStream", "label": "consumer,changeStream", "required": false, "type": "object", "javaType": "com.mongodb.client.model.changestream.FullDocument", "enum": [ "default", "updateLookup", "required", "whenAvailable" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "default", "description": "Specifies whether changeStream consumer include a copy of the full docume [...]
- "streamFilter": { "index": 46, "kind": "parameter", "displayName": "Stream Filter", "group": "changeStream", "label": "consumer,changeStream", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Filter condition for change streams consumer." },
- "authSource": { "index": 47, "kind": "parameter", "displayName": "Auth Source", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The database name associated with the user's credentials." },
- "password": { "index": 48, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "User password for mongodb connection" },
- "username": { "index": 49, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Username for mongodb connection" },
- "persistentId": { "index": 50, "kind": "parameter", "displayName": "Persistent Id", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "One tail tracking collection can host many trackers for several tailable consumers. To keep them separate, each tracker should have its own unique persistentId." },
- "persistentTailTracking": { "index": 51, "kind": "parameter", "displayName": "Persistent Tail Tracking", "group": "tail", "label": "consumer,tail", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable persistent tail tracking, which is a mechanism to keep track of the last consumed message across system restarts. The next time the system is up, the endpoint will recover the [...]
- "tailTrackCollection": { "index": 52, "kind": "parameter", "displayName": "Tail Track Collection", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Collection where tail tracking information will be persisted. If not specified, MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default." },
- "tailTrackDb": { "index": 53, "kind": "parameter", "displayName": "Tail Track Db", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Indicates what database the tail tracking mechanism will persist to. If not specified, the current database will be picked by default. Dynamicity will not be taken into account even if enabled, i.e., the tail tracking d [...]
- "tailTrackField": { "index": 54, "kind": "parameter", "displayName": "Tail Track Field", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Field where the last tracked value will be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will be used by default." },
- "tailTrackIncreasingField": { "index": 55, "kind": "parameter", "displayName": "Tail Track Increasing Field", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Correlation field in the incoming record which is of increasing nature and will be used to position the tailing cursor every time it is generated. The cursor will be (re)created with a query o [...]
+ "consumerType": { "index": 10, "kind": "parameter", "displayName": "Consumer Type", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "tailable", "changeStreams" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "tailable", "description": "Consumer type." },
+ "fullDocument": { "index": 11, "kind": "parameter", "displayName": "Full Document", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "com.mongodb.client.model.changestream.FullDocument", "enum": [ "default", "updateLookup", "required", "whenAvailable" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "default", "description": "Specifies whether changeStream consumer include a copy of the full document when modified [...]
+ "persistentId": { "index": 12, "kind": "parameter", "displayName": "Persistent Id", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "One tail tracking collection can host many trackers for several tailable consumers. To keep them separate, each tracker should have its own unique persistentId." },
+ "persistentTailTracking": { "index": 13, "kind": "parameter", "displayName": "Persistent Tail Tracking", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable persistent tail tracking, which is a mechanism to keep track of the last consumed message across system restarts. The next time the system is up, the endpoint will recover the [...]
+ "tailTrackCollection": { "index": 14, "kind": "parameter", "displayName": "Tail Track Collection", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Collection where tail tracking information will be persisted. If not specified, MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default." },
+ "tailTrackDb": { "index": 15, "kind": "parameter", "displayName": "Tail Track Db", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Indicates what database the tail tracking mechanism will persist to. If not specified, the current database will be picked by default. Dynamicity will not be taken into account even if enabled, i.e., the tail tracking da [...]
+ "tailTrackField": { "index": 16, "kind": "parameter", "displayName": "Tail Track Field", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Field where the last tracked value will be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will be used by default." },
+ "tailTrackIncreasingField": { "index": 17, "kind": "parameter", "displayName": "Tail Track Increasing Field", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Correlation field in the incoming record which is of increasing nature and will be used to position the tailing cursor every time it is generated. The cursor will be (re)created with a query of [...]
+ "bridgeErrorHandler": { "index": 18, "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming [...]
+ "exceptionHandler": { "index": 19, "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By de [...]
+ "exchangePattern": { "index": 20, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
+ "lazyStartProducer": { "index": 21, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a produ [...]
+ "appName": { "index": 22, "kind": "parameter", "displayName": "App Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the logical name of the application. The application name may be used by the client to identify the application to the server, for use in server logs, slow query logs, and profile collection. Default: null" },
+ "compressors": { "index": 23, "kind": "parameter", "displayName": "Compressors", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies one or more compression algorithms that the driver will attempt to use to compress requests sent to the connected MongoDB instance. Possible values include: zlib, snappy, and zstd. Default: null" },
+ "connectTimeoutMS": { "index": 24, "kind": "parameter", "displayName": "Connect Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10000", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver waits for a connection to open before timing out. A value of 0 instructs the driver to never time out while wait [...]
+ "cursorRegenerationDelay": { "index": 25, "kind": "parameter", "displayName": "Cursor Regeneration Delay", "group": "advanced", "label": "advanced", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1000", "description": "MongoDB tailable cursors will block until new data arrives. If no new data is inserted, after some time the cursor will be automatically freed and closed by the MongoDB server. The c [...]
+ "directConnection": { "index": 26, "kind": "parameter", "displayName": "Direct Connection", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver must connect to the host directly. Default: false" },
+ "dynamicity": { "index": 27, "kind": "parameter", "displayName": "Dynamicity", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether this endpoint will attempt to dynamically resolve the target database and collection from the incoming Exchange properties. Can be used to override at runtime the database and collection specified [...]
+ "heartbeatFrequencyMS": { "index": 28, "kind": "parameter", "displayName": "Heartbeat Frequency MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "heartbeatFrequencyMS controls when the driver checks the state of the MongoDB deployment. Specify the interval (in milliseconds) between checks, counted from the end of the previous check until the be [...]
+ "loadBalanced": { "index": 29, "kind": "parameter", "displayName": "Load Balanced", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If true the driver will assume that it's connecting to MongoDB through a load balancer." },
+ "localThresholdMS": { "index": 30, "kind": "parameter", "displayName": "Local Threshold MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "15", "description": "The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances. Default: 15 milliseconds." },
+ "maxConnecting": { "index": 31, "kind": "parameter", "displayName": "Max Connecting", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2", "description": "Specifies the maximum number of connections a pool may be establishing concurrently. Default: 2" },
+ "maxIdleTimeMS": { "index": 32, "kind": "parameter", "displayName": "Max Idle Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will allow a pooled connection to idle before closing the connection. A value of 0 indicates that there is no upper bound [...]
+ "maxLifeTimeMS": { "index": 33, "kind": "parameter", "displayName": "Max Life Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will continue to use a pooled connection before closing the connection. A value of 0 indicates that there is no upper bou [...]
+ "maxPoolSize": { "index": 34, "kind": "parameter", "displayName": "Max Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100", "description": "The maximum number of connections in the connection pool. The default value is 100." },
+ "maxStalenessSeconds": { "index": 35, "kind": "parameter", "displayName": "Max Staleness Seconds", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "Specifies, in seconds, how stale a secondary can be before the driver stops communicating with that secondary. The minimum value is either 90 seconds or the heartbeat frequency plu [...]
+ "minPoolSize": { "index": 36, "kind": "parameter", "displayName": "Min Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the minimum number of connections that must exist at any moment in a single connection pool. Default: 0" },
+ "readPreference": { "index": 37, "kind": "parameter", "displayName": "Read Preference", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "PRIMARY", "PRIMARY_PREFERRED", "SECONDARY", "SECONDARY_PREFERRED", "NEAREST" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "PRIMARY", "description": "Configure how MongoDB clients route read operations to the members of a replica set. Possible val [...]
+ "readPreferenceTags": { "index": 38, "kind": "parameter", "displayName": "Read Preference Tags", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "A representation of a tag set as a comma-separated list of colon-separated key-value pairs, e.g. dc:ny,rack:1. Spaces are stripped from the beginning and end of all keys and values. To specify a list of tag [...]
+ "replicaSet": { "index": 39, "kind": "parameter", "displayName": "Replica Set", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies that the connection string provided includes multiple hosts. When specified, the driver attempts to find all members of that set." },
+ "retryReads": { "index": 40, "kind": "parameter", "displayName": "Retry Reads", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported read operations if they fail due to a network error. Default: true" },
+ "retryWrites": { "index": 41, "kind": "parameter", "displayName": "Retry Writes", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported write operations if they fail due to a network error. Default: true" },
+ "serverSelectionTimeoutMS": { "index": 42, "kind": "parameter", "displayName": "Server Selection Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30000", "description": "Specifies how long (in milliseconds) to block for server selection before throwing an exception. Default: 30,000 milliseconds." },
+ "socketTimeoutMS": { "index": 43, "kind": "parameter", "displayName": "Socket Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will wait to send or receive a request before timing out. A value of 0 instructs the driver to never time out while wa [...]
+ "srvMaxHosts": { "index": 44, "kind": "parameter", "displayName": "Srv Max Hosts", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "The maximum number of hosts from the SRV record to connect to." },
+ "srvServiceName": { "index": 45, "kind": "parameter", "displayName": "Srv Service Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "mongodb", "description": "Specifies the service name of the SRV resource recordsthe driver retrieves to construct your seed list. You must use the DNS Seed List Connection Format in your connection URI to use this [...]
+ "waitQueueTimeoutMS": { "index": 46, "kind": "parameter", "displayName": "Wait Queue Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "120000", "description": "Specifies the maximum amount of time, in milliseconds that a thread may wait for a connection to become available. Default: 120000 (120 seconds)" },
+ "writeConcern": { "index": 47, "kind": "parameter", "displayName": "Write Concern", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "ACKNOWLEDGED", "W1", "W2", "W3", "UNACKNOWLEDGED", "JOURNALED", "MAJORITY" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "ACKNOWLEDGED", "description": "Configure the connection bean with the level of acknowledgment requested from MongoDB for write op [...]
+ "writeResultAsHeader": { "index": 48, "kind": "parameter", "displayName": "Write Result As Header", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "In write operations, it determines whether instead of returning WriteResult as the body of the OUT message, we transfer the IN message to the OUT and attach the WriteResult as a header." },
+ "zlibCompressionLevel": { "index": 49, "kind": "parameter", "displayName": "Zlib Compression Level", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies the degree of compression that Zlib should use to decrease the size of requests to the connected MongoDB instance. The level can range from -1 to 9, with lower values compressing faster (but [...]
+ "streamFilter": { "index": 50, "kind": "parameter", "displayName": "Stream Filter", "group": "changeStream", "label": "consumer,changeStream", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Filter condition for change streams consumer." },
+ "authSource": { "index": 51, "kind": "parameter", "displayName": "Auth Source", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The database name associated with the user's credentials." },
+ "password": { "index": 52, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "User password for mongodb connection" },
+ "tls": { "index": 53, "kind": "parameter", "displayName": "Tls", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that all communication with MongoDB instances should use TLS. Supersedes the ssl option. Default: false" },
+ "tlsAllowInvalidHostnames": { "index": 54, "kind": "parameter", "displayName": "Tls Allow Invalid Hostnames", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver should allow invalid hostnames in the certificate for TLS connections. Supersedes sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by setti [...]
+ "username": { "index": 55, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Username for mongodb connection" }
}
}
diff --git a/components/camel-mongodb/src/generated/resources/META-INF/org/apache/camel/component/mongodb/mongodb.json b/components/camel-mongodb/src/generated/resources/META-INF/org/apache/camel/component/mongodb/mongodb.json
index 80793d32e1a..cc4210837ff 100644
--- a/components/camel-mongodb/src/generated/resources/META-INF/org/apache/camel/component/mongodb/mongodb.json
+++ b/components/camel-mongodb/src/generated/resources/META-INF/org/apache/camel/component/mongodb/mongodb.json
@@ -68,51 +68,51 @@
"mongoConnection": { "index": 7, "kind": "parameter", "displayName": "Mongo Connection", "group": "common", "label": "", "required": false, "type": "object", "javaType": "com.mongodb.client.MongoClient", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the connection bean used as a client for connecting to a database." },
"operation": { "index": 8, "kind": "parameter", "displayName": "Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.mongodb.MongoDbOperation", "enum": [ "findById", "findOneAndDelete", "findOneAndReplace", "findOneAndUpdate", "findOneByQuery", "findAll", "findDistinct", "insert", "save", "update", "remove", "bulkWrite", "aggregate", "getDbStats", "getColStats", "count", "command" ], "deprecated": false, "autowired": [...]
"outputType": { "index": 9, "kind": "parameter", "displayName": "Output Type", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "org.apache.camel.component.mongodb.MongoDbOutputType", "enum": [ "DocumentList", "Document", "MongoIterable" ], "deprecated": false, "autowired": false, "secret": false, "description": "Convert the output of the producer to the selected type: DocumentList Document or MongoIterable. DocumentList or MongoIterable applies [...]
- "consumerType": { "index": 10, "kind": "parameter", "displayName": "Consumer Type", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Consumer type." },
- "bridgeErrorHandler": { "index": 11, "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming [...]
- "exceptionHandler": { "index": 12, "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By de [...]
- "exchangePattern": { "index": 13, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "lazyStartProducer": { "index": 14, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a produ [...]
- "appName": { "index": 15, "kind": "parameter", "displayName": "App Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the logical name of the application. The application name may be used by the client to identify the application to the server, for use in server logs, slow query logs, and profile collection. Default: null" },
- "compressors": { "index": 16, "kind": "parameter", "displayName": "Compressors", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies one or more compression algorithms that the driver will attempt to use to compress requests sent to the connected MongoDB instance. Possible values include: zlib, snappy, and zstd. Default: null" },
- "connectTimeoutMS": { "index": 17, "kind": "parameter", "displayName": "Connect Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10000", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver waits for a connection to open before timing out. A value of 0 instructs the driver to never time out while wait [...]
- "cursorRegenerationDelay": { "index": 18, "kind": "parameter", "displayName": "Cursor Regeneration Delay", "group": "advanced", "label": "advanced", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1000", "description": "MongoDB tailable cursors will block until new data arrives. If no new data is inserted, after some time the cursor will be automatically freed and closed by the MongoDB server. The c [...]
- "directConnection": { "index": 19, "kind": "parameter", "displayName": "Direct Connection", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver must connect to the host directly. Default: false" },
- "dynamicity": { "index": 20, "kind": "parameter", "displayName": "Dynamicity", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether this endpoint will attempt to dynamically resolve the target database and collection from the incoming Exchange properties. Can be used to override at runtime the database and collection specified [...]
- "heartbeatFrequencyMS": { "index": 21, "kind": "parameter", "displayName": "Heartbeat Frequency MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "heartbeatFrequencyMS controls when the driver checks the state of the MongoDB deployment. Specify the interval (in milliseconds) between checks, counted from the end of the previous check until the be [...]
- "loadBalanced": { "index": 22, "kind": "parameter", "displayName": "Load Balanced", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If true the driver will assume that it's connecting to MongoDB through a load balancer." },
- "localThresholdMS": { "index": 23, "kind": "parameter", "displayName": "Local Threshold MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "15", "description": "The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances. Default: 15 milliseconds." },
- "maxConnecting": { "index": 24, "kind": "parameter", "displayName": "Max Connecting", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2", "description": "Specifies the maximum number of connections a pool may be establishing concurrently. Default: 2" },
- "maxIdleTimeMS": { "index": 25, "kind": "parameter", "displayName": "Max Idle Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will allow a pooled connection to idle before closing the connection. A value of 0 indicates that there is no upper bound [...]
- "maxLifeTimeMS": { "index": 26, "kind": "parameter", "displayName": "Max Life Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will continue to use a pooled connection before closing the connection. A value of 0 indicates that there is no upper bou [...]
- "maxPoolSize": { "index": 27, "kind": "parameter", "displayName": "Max Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100", "description": "The maximum number of connections in the connection pool. The default value is 100." },
- "maxStalenessSeconds": { "index": 28, "kind": "parameter", "displayName": "Max Staleness Seconds", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "Specifies, in seconds, how stale a secondary can be before the driver stops communicating with that secondary. The minimum value is either 90 seconds or the heartbeat frequency plu [...]
- "minPoolSize": { "index": 29, "kind": "parameter", "displayName": "Min Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the minimum number of connections that must exist at any moment in a single connection pool. Default: 0" },
- "readPreference": { "index": 30, "kind": "parameter", "displayName": "Read Preference", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "PRIMARY", "PRIMARY_PREFERRED", "SECONDARY", "SECONDARY_PREFERRED", "NEAREST" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "PRIMARY", "description": "Configure how MongoDB clients route read operations to the members of a replica set. Possible val [...]
- "readPreferenceTags": { "index": 31, "kind": "parameter", "displayName": "Read Preference Tags", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "A representation of a tag set as a comma-separated list of colon-separated key-value pairs, e.g. dc:ny,rack:1. Spaces are stripped from the beginning and end of all keys and values. To specify a list of tag [...]
- "replicaSet": { "index": 32, "kind": "parameter", "displayName": "Replica Set", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies that the connection string provided includes multiple hosts. When specified, the driver attempts to find all members of that set." },
- "retryReads": { "index": 33, "kind": "parameter", "displayName": "Retry Reads", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported read operations if they fail due to a network error. Default: true" },
- "retryWrites": { "index": 34, "kind": "parameter", "displayName": "Retry Writes", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported write operations if they fail due to a network error. Default: true" },
- "serverSelectionTimeoutMS": { "index": 35, "kind": "parameter", "displayName": "Server Selection Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30000", "description": "Specifies how long (in milliseconds) to block for server selection before throwing an exception. Default: 30,000 milliseconds." },
- "socketTimeoutMS": { "index": 36, "kind": "parameter", "displayName": "Socket Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will wait to send or receive a request before timing out. A value of 0 instructs the driver to never time out while wa [...]
- "srvMaxHosts": { "index": 37, "kind": "parameter", "displayName": "Srv Max Hosts", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "The maximum number of hosts from the SRV record to connect to." },
- "srvServiceName": { "index": 38, "kind": "parameter", "displayName": "Srv Service Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "mongodb", "description": "Specifies the service name of the SRV resource recordsthe driver retrieves to construct your seed list. You must use the DNS Seed List Connection Format in your connection URI to use this [...]
- "tls": { "index": 39, "kind": "parameter", "displayName": "Tls", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that all communication with MongoDB instances should use TLS. Supersedes the ssl option. Default: false" },
- "tlsAllowInvalidHostnames": { "index": 40, "kind": "parameter", "displayName": "Tls Allow Invalid Hostnames", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver should allow invalid hostnames in the certificate for TLS connections. Supersedes sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by setti [...]
- "waitQueueTimeoutMS": { "index": 41, "kind": "parameter", "displayName": "Wait Queue Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "120000", "description": "Specifies the maximum amount of time, in milliseconds that a thread may wait for a connection to become available. Default: 120000 (120 seconds)" },
- "writeConcern": { "index": 42, "kind": "parameter", "displayName": "Write Concern", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "ACKNOWLEDGED", "W1", "W2", "W3", "UNACKNOWLEDGED", "JOURNALED", "MAJORITY" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "ACKNOWLEDGED", "description": "Configure the connection bean with the level of acknowledgment requested from MongoDB for write op [...]
- "writeResultAsHeader": { "index": 43, "kind": "parameter", "displayName": "Write Result As Header", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "In write operations, it determines whether instead of returning WriteResult as the body of the OUT message, we transfer the IN message to the OUT and attach the WriteResult as a header." },
- "zlibCompressionLevel": { "index": 44, "kind": "parameter", "displayName": "Zlib Compression Level", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies the degree of compression that Zlib should use to decrease the size of requests to the connected MongoDB instance. The level can range from -1 to 9, with lower values compressing faster (but [...]
- "fullDocument": { "index": 45, "kind": "parameter", "displayName": "Full Document", "group": "changeStream", "label": "consumer,changeStream", "required": false, "type": "object", "javaType": "com.mongodb.client.model.changestream.FullDocument", "enum": [ "default", "updateLookup", "required", "whenAvailable" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "default", "description": "Specifies whether changeStream consumer include a copy of the full docume [...]
- "streamFilter": { "index": 46, "kind": "parameter", "displayName": "Stream Filter", "group": "changeStream", "label": "consumer,changeStream", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Filter condition for change streams consumer." },
- "authSource": { "index": 47, "kind": "parameter", "displayName": "Auth Source", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The database name associated with the user's credentials." },
- "password": { "index": 48, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "User password for mongodb connection" },
- "username": { "index": 49, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Username for mongodb connection" },
- "persistentId": { "index": 50, "kind": "parameter", "displayName": "Persistent Id", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "One tail tracking collection can host many trackers for several tailable consumers. To keep them separate, each tracker should have its own unique persistentId." },
- "persistentTailTracking": { "index": 51, "kind": "parameter", "displayName": "Persistent Tail Tracking", "group": "tail", "label": "consumer,tail", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable persistent tail tracking, which is a mechanism to keep track of the last consumed message across system restarts. The next time the system is up, the endpoint will recover the [...]
- "tailTrackCollection": { "index": 52, "kind": "parameter", "displayName": "Tail Track Collection", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Collection where tail tracking information will be persisted. If not specified, MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default." },
- "tailTrackDb": { "index": 53, "kind": "parameter", "displayName": "Tail Track Db", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Indicates what database the tail tracking mechanism will persist to. If not specified, the current database will be picked by default. Dynamicity will not be taken into account even if enabled, i.e., the tail tracking d [...]
- "tailTrackField": { "index": 54, "kind": "parameter", "displayName": "Tail Track Field", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Field where the last tracked value will be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will be used by default." },
- "tailTrackIncreasingField": { "index": 55, "kind": "parameter", "displayName": "Tail Track Increasing Field", "group": "tail", "label": "consumer,tail", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Correlation field in the incoming record which is of increasing nature and will be used to position the tailing cursor every time it is generated. The cursor will be (re)created with a query o [...]
+ "consumerType": { "index": 10, "kind": "parameter", "displayName": "Consumer Type", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "tailable", "changeStreams" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "tailable", "description": "Consumer type." },
+ "fullDocument": { "index": 11, "kind": "parameter", "displayName": "Full Document", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "com.mongodb.client.model.changestream.FullDocument", "enum": [ "default", "updateLookup", "required", "whenAvailable" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "default", "description": "Specifies whether changeStream consumer include a copy of the full document when modified [...]
+ "persistentId": { "index": 12, "kind": "parameter", "displayName": "Persistent Id", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "One tail tracking collection can host many trackers for several tailable consumers. To keep them separate, each tracker should have its own unique persistentId." },
+ "persistentTailTracking": { "index": 13, "kind": "parameter", "displayName": "Persistent Tail Tracking", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Enable persistent tail tracking, which is a mechanism to keep track of the last consumed message across system restarts. The next time the system is up, the endpoint will recover the [...]
+ "tailTrackCollection": { "index": 14, "kind": "parameter", "displayName": "Tail Track Collection", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Collection where tail tracking information will be persisted. If not specified, MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default." },
+ "tailTrackDb": { "index": 15, "kind": "parameter", "displayName": "Tail Track Db", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Indicates what database the tail tracking mechanism will persist to. If not specified, the current database will be picked by default. Dynamicity will not be taken into account even if enabled, i.e., the tail tracking da [...]
+ "tailTrackField": { "index": 16, "kind": "parameter", "displayName": "Tail Track Field", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Field where the last tracked value will be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will be used by default." },
+ "tailTrackIncreasingField": { "index": 17, "kind": "parameter", "displayName": "Tail Track Increasing Field", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Correlation field in the incoming record which is of increasing nature and will be used to position the tailing cursor every time it is generated. The cursor will be (re)created with a query of [...]
+ "bridgeErrorHandler": { "index": 18, "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming [...]
+ "exceptionHandler": { "index": 19, "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By de [...]
+ "exchangePattern": { "index": 20, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
+ "lazyStartProducer": { "index": 21, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a produ [...]
+ "appName": { "index": 22, "kind": "parameter", "displayName": "App Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the logical name of the application. The application name may be used by the client to identify the application to the server, for use in server logs, slow query logs, and profile collection. Default: null" },
+ "compressors": { "index": 23, "kind": "parameter", "displayName": "Compressors", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies one or more compression algorithms that the driver will attempt to use to compress requests sent to the connected MongoDB instance. Possible values include: zlib, snappy, and zstd. Default: null" },
+ "connectTimeoutMS": { "index": 24, "kind": "parameter", "displayName": "Connect Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10000", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver waits for a connection to open before timing out. A value of 0 instructs the driver to never time out while wait [...]
+ "cursorRegenerationDelay": { "index": 25, "kind": "parameter", "displayName": "Cursor Regeneration Delay", "group": "advanced", "label": "advanced", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1000", "description": "MongoDB tailable cursors will block until new data arrives. If no new data is inserted, after some time the cursor will be automatically freed and closed by the MongoDB server. The c [...]
+ "directConnection": { "index": 26, "kind": "parameter", "displayName": "Direct Connection", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver must connect to the host directly. Default: false" },
+ "dynamicity": { "index": 27, "kind": "parameter", "displayName": "Dynamicity", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether this endpoint will attempt to dynamically resolve the target database and collection from the incoming Exchange properties. Can be used to override at runtime the database and collection specified [...]
+ "heartbeatFrequencyMS": { "index": 28, "kind": "parameter", "displayName": "Heartbeat Frequency MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "heartbeatFrequencyMS controls when the driver checks the state of the MongoDB deployment. Specify the interval (in milliseconds) between checks, counted from the end of the previous check until the be [...]
+ "loadBalanced": { "index": 29, "kind": "parameter", "displayName": "Load Balanced", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If true the driver will assume that it's connecting to MongoDB through a load balancer." },
+ "localThresholdMS": { "index": 30, "kind": "parameter", "displayName": "Local Threshold MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "15", "description": "The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances. Default: 15 milliseconds." },
+ "maxConnecting": { "index": 31, "kind": "parameter", "displayName": "Max Connecting", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2", "description": "Specifies the maximum number of connections a pool may be establishing concurrently. Default: 2" },
+ "maxIdleTimeMS": { "index": 32, "kind": "parameter", "displayName": "Max Idle Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will allow a pooled connection to idle before closing the connection. A value of 0 indicates that there is no upper bound [...]
+ "maxLifeTimeMS": { "index": 33, "kind": "parameter", "displayName": "Max Life Time MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will continue to use a pooled connection before closing the connection. A value of 0 indicates that there is no upper bou [...]
+ "maxPoolSize": { "index": 34, "kind": "parameter", "displayName": "Max Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100", "description": "The maximum number of connections in the connection pool. The default value is 100." },
+ "maxStalenessSeconds": { "index": 35, "kind": "parameter", "displayName": "Max Staleness Seconds", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "Specifies, in seconds, how stale a secondary can be before the driver stops communicating with that secondary. The minimum value is either 90 seconds or the heartbeat frequency plu [...]
+ "minPoolSize": { "index": 36, "kind": "parameter", "displayName": "Min Pool Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the minimum number of connections that must exist at any moment in a single connection pool. Default: 0" },
+ "readPreference": { "index": 37, "kind": "parameter", "displayName": "Read Preference", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "PRIMARY", "PRIMARY_PREFERRED", "SECONDARY", "SECONDARY_PREFERRED", "NEAREST" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "PRIMARY", "description": "Configure how MongoDB clients route read operations to the members of a replica set. Possible val [...]
+ "readPreferenceTags": { "index": 38, "kind": "parameter", "displayName": "Read Preference Tags", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "A representation of a tag set as a comma-separated list of colon-separated key-value pairs, e.g. dc:ny,rack:1. Spaces are stripped from the beginning and end of all keys and values. To specify a list of tag [...]
+ "replicaSet": { "index": 39, "kind": "parameter", "displayName": "Replica Set", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies that the connection string provided includes multiple hosts. When specified, the driver attempts to find all members of that set." },
+ "retryReads": { "index": 40, "kind": "parameter", "displayName": "Retry Reads", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported read operations if they fail due to a network error. Default: true" },
+ "retryWrites": { "index": 41, "kind": "parameter", "displayName": "Retry Writes", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Specifies that the driver must retry supported write operations if they fail due to a network error. Default: true" },
+ "serverSelectionTimeoutMS": { "index": 42, "kind": "parameter", "displayName": "Server Selection Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30000", "description": "Specifies how long (in milliseconds) to block for server selection before throwing an exception. Default: 30,000 milliseconds." },
+ "socketTimeoutMS": { "index": 43, "kind": "parameter", "displayName": "Socket Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0", "description": "Specifies the maximum amount of time, in milliseconds, the Java driver will wait to send or receive a request before timing out. A value of 0 instructs the driver to never time out while wa [...]
+ "srvMaxHosts": { "index": 44, "kind": "parameter", "displayName": "Srv Max Hosts", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "The maximum number of hosts from the SRV record to connect to." },
+ "srvServiceName": { "index": 45, "kind": "parameter", "displayName": "Srv Service Name", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "mongodb", "description": "Specifies the service name of the SRV resource recordsthe driver retrieves to construct your seed list. You must use the DNS Seed List Connection Format in your connection URI to use this [...]
+ "waitQueueTimeoutMS": { "index": 46, "kind": "parameter", "displayName": "Wait Queue Timeout MS", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "120000", "description": "Specifies the maximum amount of time, in milliseconds that a thread may wait for a connection to become available. Default: 120000 (120 seconds)" },
+ "writeConcern": { "index": 47, "kind": "parameter", "displayName": "Write Concern", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "ACKNOWLEDGED", "W1", "W2", "W3", "UNACKNOWLEDGED", "JOURNALED", "MAJORITY" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "ACKNOWLEDGED", "description": "Configure the connection bean with the level of acknowledgment requested from MongoDB for write op [...]
+ "writeResultAsHeader": { "index": 48, "kind": "parameter", "displayName": "Write Result As Header", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "In write operations, it determines whether instead of returning WriteResult as the body of the OUT message, we transfer the IN message to the OUT and attach the WriteResult as a header." },
+ "zlibCompressionLevel": { "index": 49, "kind": "parameter", "displayName": "Zlib Compression Level", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies the degree of compression that Zlib should use to decrease the size of requests to the connected MongoDB instance. The level can range from -1 to 9, with lower values compressing faster (but [...]
+ "streamFilter": { "index": 50, "kind": "parameter", "displayName": "Stream Filter", "group": "changeStream", "label": "consumer,changeStream", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Filter condition for change streams consumer." },
+ "authSource": { "index": 51, "kind": "parameter", "displayName": "Auth Source", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The database name associated with the user's credentials." },
+ "password": { "index": 52, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "User password for mongodb connection" },
+ "tls": { "index": 53, "kind": "parameter", "displayName": "Tls", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that all communication with MongoDB instances should use TLS. Supersedes the ssl option. Default: false" },
+ "tlsAllowInvalidHostnames": { "index": 54, "kind": "parameter", "displayName": "Tls Allow Invalid Hostnames", "group": "security", "label": "security", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Specifies that the driver should allow invalid hostnames in the certificate for TLS connections. Supersedes sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by setti [...]
+ "username": { "index": 55, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "description": "Username for mongodb connection" }
}
}
diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
index 35db6337129..d4866d3e82f 100644
--- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
+++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbComponent.java
@@ -57,9 +57,7 @@ public class MongoDbComponent extends DefaultComponent {
protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
MongoDbEndpoint endpoint = new MongoDbEndpoint(uri, this);
endpoint.setConnectionBean(remaining);
- endpoint.setMongoConnection(mongoConnection);
setProperties(endpoint, parameters);
-
return endpoint;
}
diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
index a8f867225cc..d5b41a87e4b 100644
--- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
+++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
@@ -95,26 +95,26 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
private boolean dynamicity;
@UriParam(label = "advanced")
private boolean writeResultAsHeader;
- @UriParam(label = "consumer")
+ @UriParam(label = "consumer", enums = "tailable,changeStreams", defaultValue = "tailable")
private String consumerType;
@UriParam(label = "advanced", defaultValue = "1000", javaType = "java.time.Duration")
private long cursorRegenerationDelay = 1000L;
- @UriParam(label = "consumer,tail")
+ @UriParam(label = "consumer")
private String tailTrackIncreasingField;
@UriParam(label = "consumer,changeStream")
private String streamFilter;
- @UriParam(label = "consumer,changeStream", enums = "default,updateLookup,required,whenAvailable", defaultValue = "default")
+ @UriParam(label = "consumer", enums = "default,updateLookup,required,whenAvailable", defaultValue = "default")
private FullDocument fullDocument = FullDocument.DEFAULT;
// persistent tail tracking
- @UriParam(label = "consumer,tail")
+ @UriParam(label = "consumer")
private boolean persistentTailTracking;
- @UriParam(label = "consumer,tail")
+ @UriParam(label = "consumer")
private String persistentId;
- @UriParam(label = "consumer,tail")
+ @UriParam(label = "consumer")
private String tailTrackDb;
- @UriParam(label = "consumer,tail")
+ @UriParam(label = "consumer")
private String tailTrackCollection;
- @UriParam(label = "consumer,tail")
+ @UriParam(label = "consumer")
private String tailTrackField;
@UriParam(label = "common")
private MongoDbOutputType outputType;
@@ -130,10 +130,10 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
@UriParam(label = "advanced")
private String replicaSet;
//Connection Configuration
- @UriParam(label = "advanced", defaultValue = "false")
- private boolean tls = false;
- @UriParam(label = "advanced", defaultValue = "false")
- private boolean tlsAllowInvalidHostnames = false;
+ @UriParam(label = "security", defaultValue = "false")
+ private boolean tls;
+ @UriParam(label = "security", defaultValue = "false")
+ private boolean tlsAllowInvalidHostnames;
@UriParam(label = "advanced", defaultValue = "10000")
private Integer connectTimeoutMS = 10000;
@UriParam(label = "advanced", defaultValue = "0")
@@ -183,7 +183,7 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
@UriParam(label = "advanced", defaultValue = "true")
private boolean retryReads = true;
@UriParam(label = "advanced", defaultValue = "false")
- private boolean directConnection = false;
+ private boolean directConnection;
@UriParam(label = "advanced")
private boolean loadBalanced;
//additional properties
@@ -206,6 +206,11 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
super(uri, component);
}
+ @Override
+ public MongoDbComponent getComponent() {
+ return (MongoDbComponent) super.getComponent();
+ }
+
@Override
public String getServiceUrl() {
if (connectionUriString != null) {
@@ -373,8 +378,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Add Index
- *
- * @param aCollection
*/
public void ensureIndex(MongoCollection<Document> aCollection, List<Bson> dynamicIndex) {
if (dynamicIndex != null && !dynamicIndex.isEmpty()) {
@@ -431,13 +434,10 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
MongoClient mongoClient;
if (this.hosts != null) {
String credentials = username == null ? "" : username;
-
if (!credentials.isEmpty()) {
credentials += this.password == null ? "@" : ":" + password + "@";
}
-
String connectionOptions = authSource == null ? "" : "/?authSource=" + authSource;
-
if (connectionUriString != null) {
mongoClient = MongoClients.create(connectionUriString);
} else {
@@ -445,9 +445,12 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
}
LOG.debug("Connection created using provided credentials");
} else {
- mongoClient = CamelContextHelper.mandatoryLookup(getCamelContext(), connectionBean, MongoClient.class);
- LOG.debug("Resolved the connection provided by {} context reference as {}", connectionBean,
- mongoConnection);
+ mongoClient = getComponent().getMongoConnection();
+ if (mongoClient == null) {
+ mongoClient = CamelContextHelper.mandatoryLookup(getCamelContext(), connectionBean, MongoClient.class);
+ LOG.debug("Resolved the connection provided by {} context reference as {}", connectionBean,
+ mongoConnection);
+ }
}
return mongoClient;
@@ -466,8 +469,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Sets the name of the MongoDB collection to bind to this endpoint
- *
- * @param collection collection name
*/
public void setCollection(String collection) {
this.collection = collection;
@@ -512,8 +513,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Sets the name of the MongoDB database to target
- *
- * @param database name of the MongoDB database
*/
public void setDatabase(String database) {
this.database = database;
@@ -525,8 +524,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Create the collection during initialisation if it doesn't exist. Default is true.
- *
- * @param createCollection true or false
*/
public void setCreateCollection(boolean createCollection) {
this.createCollection = createCollection;
@@ -538,8 +535,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Sets the Mongo instance that represents the backing connection
- *
- * @param mongoConnection the connection to the database
*/
public void setMongoConnection(MongoClient mongoConnection) {
this.mongoConnection = mongoConnection;
@@ -605,8 +600,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Indicates what database the tail tracking mechanism will persist to. If not specified, the current database will
* be picked by default. Dynamicity will not be taken into account even if enabled, i.e., the tail tracking database
* will not vary past endpoint initialization.
- *
- * @param tailTrackDb database name
*/
public void setTailTrackDb(String tailTrackDb) {
this.tailTrackDb = tailTrackDb;
@@ -619,8 +612,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Collection where tail tracking information will be persisted. If not specified,
* {@link MongoDbTailTrackingConfig#DEFAULT_COLLECTION} will be used by default.
- *
- * @param tailTrackCollection collection name
*/
public void setTailTrackCollection(String tailTrackCollection) {
this.tailTrackCollection = tailTrackCollection;
@@ -633,8 +624,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Field where the last tracked value will be placed. If not specified,
* {@link MongoDbTailTrackingConfig#DEFAULT_FIELD} will be used by default.
- *
- * @param tailTrackField field name
*/
public void setTailTrackField(String tailTrackField) {
this.tailTrackField = tailTrackField;
@@ -644,8 +633,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Enable persistent tail tracking, which is a mechanism to keep track of the last consumed message across system
* restarts. The next time the system is up, the endpoint will recover the cursor from the point where it last
* stopped slurping records.
- *
- * @param persistentTailTracking true or false
*/
public void setPersistentTailTracking(boolean persistentTailTracking) {
this.persistentTailTracking = persistentTailTracking;
@@ -661,8 +648,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* greater than lastValue (possibly recovered from persistent tail tracking). Can be of type Integer, Date, String,
* etc. NOTE: No support for dot notation at the current time, so the field should be at the top level of the
* document.
- *
- * @param tailTrackIncreasingField
*/
public void setTailTrackIncreasingField(String tailTrackIncreasingField) {
this.tailTrackIncreasingField = tailTrackIncreasingField;
@@ -687,8 +672,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* cursor will be automatically freed and closed by the MongoDB server. The client is expected to regenerate the
* cursor if needed. This value specifies the time to wait before attempting to fetch a new cursor, and if the
* attempt fails, how long before the next attempt is made. Default value is 1000ms.
- *
- * @param cursorRegenerationDelay delay specified in milliseconds
*/
public void setCursorRegenerationDelay(long cursorRegenerationDelay) {
this.cursorRegenerationDelay = cursorRegenerationDelay;
@@ -701,8 +684,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* One tail tracking collection can host many trackers for several tailable consumers. To keep them separate, each
* tracker should have its own unique persistentId.
- *
- * @param persistentId the value of the persistent ID to use for this tailable consumer
*/
public void setPersistentId(String persistentId) {
this.persistentId = persistentId;
@@ -719,8 +700,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* In write operations, it determines whether instead of returning WriteResult as the body of the OUT message, we
* transfer the IN message to the OUT and attach the WriteResult as a header.
- *
- * @param writeResultAsHeader flag to indicate if this option is enabled
*/
public void setWriteResultAsHeader(boolean writeResultAsHeader) {
this.writeResultAsHeader = writeResultAsHeader;
@@ -733,8 +712,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Convert the output of the producer to the selected type: DocumentList Document or MongoIterable. DocumentList or
* MongoIterable applies to findAll and aggregate. Document applies to all other operations.
- *
- * @param outputType
*/
public void setOutputType(MongoDbOutputType outputType) {
this.outputType = outputType;
@@ -775,8 +752,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Configure the connection bean with the level of acknowledgment requested from MongoDB for write operations to a
* standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1, W2, W3, UNACKNOWLEDGED, JOURNALED
* or MAJORITY.
- *
- * @param writeConcern
*/
public void setWriteConcern(String writeConcern) {
this.writeConcern = writeConcern;
@@ -797,8 +772,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Configure how MongoDB clients route read operations to the members of a replica set. Possible values are PRIMARY,
* PRIMARY_PREFERRED, SECONDARY, SECONDARY_PREFERRED or NEAREST
- *
- * @param readPreference
*/
public void setReadPreference(String readPreference) {
this.readPreference = readPreference;
@@ -819,8 +792,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Username for mongodb connection
- *
- * @param username
*/
public void setUsername(String username) {
this.username = username;
@@ -832,8 +803,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* User password for mongodb connection
- *
- * @param password
*/
public void setPassword(String password) {
this.password = password;
@@ -847,8 +816,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Host address of mongodb server in `[host]:[port]` format. It's possible to also use more than one address, as a
* comma separated list of hosts: `[host1]:[port1],[host2]:[port2]`. If this parameter is specified, the provided
* connectionBean is ignored.
- *
- * @param hosts
*/
public void setHosts(String hosts) {
this.hosts = hosts;
@@ -860,8 +827,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* The database name associated with the user's credentials.
- *
- * @param authSource
*/
public void setAuthSource(String authSource) {
this.authSource = authSource;
@@ -870,8 +835,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies how long (in milliseconds) to block for server selection before throwing an exception. Default: 30,000
* milliseconds.
- *
- * @param serverSelectionTimeoutMS
*/
public void setServerSelectionTimeoutMS(Integer serverSelectionTimeoutMS) {
this.serverSelectionTimeoutMS = serverSelectionTimeoutMS;
@@ -884,8 +847,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances.
* Default: 15 milliseconds.
- *
- * @param localThresholdMS
*/
public void setLocalThresholdMS(Integer localThresholdMS) {
this.localThresholdMS = localThresholdMS;
@@ -899,8 +860,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* heartbeatFrequencyMS controls when the driver checks the state of the MongoDB deployment. Specify the interval
* (in milliseconds) between checks, counted from the end of the previous check until the beginning of the next one.
* Default: Single-threaded drivers: 60 seconds. Multithreaded drivers: 10 seconds.
- *
- * @param heartbeatFrequencyMS
*/
public void setHeartbeatFrequencyMS(Integer heartbeatFrequencyMS) {
this.heartbeatFrequencyMS = heartbeatFrequencyMS;
@@ -913,8 +872,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies that the connection string provided includes multiple hosts. When specified, the driver attempts to
* find all members of that set.
- *
- * @param replicaSet
*/
public void setReplicaSet(String replicaSet) {
this.replicaSet = replicaSet;
@@ -926,8 +883,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies that all communication with MongoDB instances should use TLS. Supersedes the ssl option. Default: false
- *
- * @param tls
*/
public void setTls(boolean tls) {
this.tls = tls;
@@ -941,8 +896,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Specifies that the driver should allow invalid hostnames in the certificate for TLS connections. Supersedes
* sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by setting tlsAllowInvalidHostnames to true.
* Default: false
- *
- * @param tlsAllowInvalidHostnames
*/
public void setTlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
this.tlsAllowInvalidHostnames = tlsAllowInvalidHostnames;
@@ -956,8 +909,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Specifies the maximum amount of time, in milliseconds, the Java driver waits for a connection to open before
* timing out. A value of 0 instructs the driver to never time out while waiting for a connection to open. Default:
* 10000 (10 seconds)
- *
- * @param connectTimeoutMS
*/
public void setConnectTimeoutMS(Integer connectTimeoutMS) {
this.connectTimeoutMS = connectTimeoutMS;
@@ -971,8 +922,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Specifies the maximum amount of time, in milliseconds, the Java driver will wait to send or receive a request
* before timing out. A value of 0 instructs the driver to never time out while waiting to send or receive a
* request. Default: 0
- *
- * @param socketTimeoutMS
*/
public void setSocketTimeoutMS(Integer socketTimeoutMS) {
this.socketTimeoutMS = socketTimeoutMS;
@@ -986,8 +935,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Specifies the maximum amount of time, in milliseconds, the Java driver will allow a pooled connection to idle
* before closing the connection. A value of 0 indicates that there is no upper bound on how long the driver can
* allow a pooled collection to be idle. Default: 0
- *
- * @param maxIdleTimeMS
*/
public void setMaxIdleTimeMS(Integer maxIdleTimeMS) {
this.maxIdleTimeMS = maxIdleTimeMS;
@@ -1001,8 +948,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Specifies the maximum amount of time, in milliseconds, the Java driver will continue to use a pooled connection
* before closing the connection. A value of 0 indicates that there is no upper bound on how long the driver can
* keep a pooled connection open. Default: 0
- *
- * @param maxLifeTimeMS
*/
public void setMaxLifeTimeMS(Integer maxLifeTimeMS) {
this.maxLifeTimeMS = maxLifeTimeMS;
@@ -1014,8 +959,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies the minimum number of connections that must exist at any moment in a single connection pool. Default: 0
- *
- * @param minPoolSize
*/
public void setMinPoolSize(Integer minPoolSize) {
this.minPoolSize = minPoolSize;
@@ -1027,8 +970,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* The maximum number of connections in the connection pool. The default value is 100.
- *
- * @param maxPoolSize
*/
public void setMaxPoolSize(Integer maxPoolSize) {
this.maxPoolSize = maxPoolSize;
@@ -1040,8 +981,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies the maximum number of connections a pool may be establishing concurrently. Default: 2
- *
- * @param maxConnecting
*/
public void setMaxConnecting(Integer maxConnecting) {
this.maxConnecting = maxConnecting;
@@ -1054,8 +993,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies the maximum amount of time, in milliseconds that a thread may wait for a connection to become
* available. Default: 120000 (120 seconds)
- *
- * @param waitQueueTimeoutMS
*/
public void setWaitQueueTimeoutMS(Integer waitQueueTimeoutMS) {
this.waitQueueTimeoutMS = waitQueueTimeoutMS;
@@ -1071,8 +1008,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* multiple readPreferenceTags, e.g., readPreferenceTags=dc:ny,rack:1;readPreferenceTags=dc:ny;readPreferenceTags=
* Note the empty value for the last one, which means match any secondary as a last resort. Order matters when using
* multiple readPreferenceTags.
- *
- * @param readPreferenceTags
*/
public void setReadPreferenceTags(String readPreferenceTags) {
this.readPreferenceTags = readPreferenceTags;
@@ -1087,8 +1022,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* The minimum value is either 90 seconds or the heartbeat frequency plus 10 seconds, whichever is greater. For more
* information, see the server documentation for the maxStalenessSeconds option. Not providing a parameter or
* explicitly specifying -1 indicates that there should be no staleness check for secondaries. Default: -1
- *
- * @param maxStalenessSeconds
*/
public void setMaxStalenessSeconds(Integer maxStalenessSeconds) {
this.maxStalenessSeconds = maxStalenessSeconds;
@@ -1101,8 +1034,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Sets the logical name of the application. The application name may be used by the client to identify the
* application to the server, for use in server logs, slow query logs, and profile collection. Default: null
- *
- * @param appName
*/
public void setAppName(String appName) {
this.appName = appName;
@@ -1115,8 +1046,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies one or more compression algorithms that the driver will attempt to use to compress requests sent to the
* connected MongoDB instance. Possible values include: zlib, snappy, and zstd. Default: null
- *
- * @param compressors
*/
public void setCompressors(String compressors) {
this.compressors = compressors;
@@ -1130,8 +1059,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Specifies the degree of compression that Zlib should use to decrease the size of requests to the connected
* MongoDB instance. The level can range from -1 to 9, with lower values compressing faster (but resulting in larger
* requests) and larger values compressing slower (but resulting in smaller requests). Default: null
- *
- * @param zlibCompressionLevel
*/
public void setZlibCompressionLevel(Integer zlibCompressionLevel) {
this.zlibCompressionLevel = zlibCompressionLevel;
@@ -1144,8 +1071,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies the service name of the SRV resource recordsthe driver retrieves to construct your seed list. You must
* use the DNS Seed List Connection Format in your connection URI to use this option. Default: mongodb
- *
- * @param srvServiceName
*/
public void setSrvServiceName(String srvServiceName) {
this.srvServiceName = srvServiceName;
@@ -1157,8 +1082,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* The maximum number of hosts from the SRV record to connect to.
- *
- * @param srvMaxHosts
*/
public void setSrvMaxHosts(Integer srvMaxHosts) {
this.srvMaxHosts = srvMaxHosts;
@@ -1171,8 +1094,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies that the driver must retry supported write operations if they fail due to a network error. Default:
* true
- *
- * @param retryWrites
*/
public void setRetryWrites(boolean retryWrites) {
this.retryWrites = retryWrites;
@@ -1184,8 +1105,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies that the driver must retry supported read operations if they fail due to a network error. Default: true
- *
- * @param retryReads
*/
public void setRetryReads(boolean retryReads) {
this.retryReads = retryReads;
@@ -1197,8 +1116,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* Specifies that the driver must connect to the host directly. Default: false
- *
- * @param directConnection
*/
public void setDirectConnection(boolean directConnection) {
this.directConnection = directConnection;
@@ -1210,8 +1127,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
/**
* If true the driver will assume that it's connecting to MongoDB through a load balancer.
- *
- * @param loadBalanced
*/
public void setLoadBalanced(boolean loadBalanced) {
this.loadBalanced = loadBalanced;
@@ -1225,8 +1140,6 @@ public class MongoDbEndpoint extends DefaultEndpoint implements EndpointServiceL
* Set the whole Connection String/Uri for mongodb endpoint. To be flexible and future proof about supporting all
* the mongodb client options
* https://www.mongodb.com/docs/drivers/java/sync/current/fundamentals/connection/connect/#connection-uri
- *
- * @param connectionUriString
*/
public void setConnectionUriString(String connectionUriString) {
this.connectionUriString = connectionUriString;
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java
index 5e459ce0642..39028de9273 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java
@@ -253,6 +253,7 @@ public interface MongoDbEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
+ * Default: tailable
* Group: consumer
*
* @param consumerType the value to set
@@ -271,7 +272,7 @@ public interface MongoDbEndpointBuilderFactory {
* <code>com.mongodb.client.model.changestream.FullDocument</code> type.
*
* Default: default
- * Group: changeStream
+ * Group: consumer
*
* @param fullDocument the value to set
* @return the dsl builder
@@ -289,7 +290,7 @@ public interface MongoDbEndpointBuilderFactory {
* <code>com.mongodb.client.model.changestream.FullDocument</code> type.
*
* Default: default
- * Group: changeStream
+ * Group: consumer
*
* @param fullDocument the value to set
* @return the dsl builder
@@ -298,62 +299,6 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("fullDocument", fullDocument);
return this;
}
- /**
- * Filter condition for change streams consumer.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: changeStream
- *
- * @param streamFilter the value to set
- * @return the dsl builder
- */
- default MongoDbEndpointConsumerBuilder streamFilter(String streamFilter) {
- doSetProperty("streamFilter", streamFilter);
- return this;
- }
- /**
- * The database name associated with the user's credentials.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param authSource the value to set
- * @return the dsl builder
- */
- default MongoDbEndpointConsumerBuilder authSource(String authSource) {
- doSetProperty("authSource", authSource);
- return this;
- }
- /**
- * User password for mongodb connection.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param password the value to set
- * @return the dsl builder
- */
- default MongoDbEndpointConsumerBuilder password(String password) {
- doSetProperty("password", password);
- return this;
- }
- /**
- * Username for mongodb connection.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param username the value to set
- * @return the dsl builder
- */
- default MongoDbEndpointConsumerBuilder username(String username) {
- doSetProperty("username", username);
- return this;
- }
/**
* One tail tracking collection can host many trackers for several
* tailable consumers. To keep them separate, each tracker should have
@@ -361,7 +306,7 @@ public interface MongoDbEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: tail
+ * Group: consumer
*
* @param persistentId the value to set
* @return the dsl builder
@@ -379,7 +324,7 @@ public interface MongoDbEndpointBuilderFactory {
* The option is a: <code>boolean</code> type.
*
* Default: false
- * Group: tail
+ * Group: consumer
*
* @param persistentTailTracking the value to set
* @return the dsl builder
@@ -397,7 +342,7 @@ public interface MongoDbEndpointBuilderFactory {
* The option will be converted to a <code>boolean</code> type.
*
* Default: false
- * Group: tail
+ * Group: consumer
*
* @param persistentTailTracking the value to set
* @return the dsl builder
@@ -413,7 +358,7 @@ public interface MongoDbEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: tail
+ * Group: consumer
*
* @param tailTrackCollection the value to set
* @return the dsl builder
@@ -430,7 +375,7 @@ public interface MongoDbEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: tail
+ * Group: consumer
*
* @param tailTrackDb the value to set
* @return the dsl builder
@@ -445,7 +390,7 @@ public interface MongoDbEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: tail
+ * Group: consumer
*
* @param tailTrackField the value to set
* @return the dsl builder
@@ -465,7 +410,7 @@ public interface MongoDbEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: tail
+ * Group: consumer
*
* @param tailTrackIncreasingField the value to set
* @return the dsl builder
@@ -474,6 +419,130 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("tailTrackIncreasingField", tailTrackIncreasingField);
return this;
}
+ /**
+ * Filter condition for change streams consumer.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: changeStream
+ *
+ * @param streamFilter the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder streamFilter(String streamFilter) {
+ doSetProperty("streamFilter", streamFilter);
+ return this;
+ }
+ /**
+ * The database name associated with the user's credentials.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param authSource the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder authSource(String authSource) {
+ doSetProperty("authSource", authSource);
+ return this;
+ }
+ /**
+ * User password for mongodb connection.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param password the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder password(String password) {
+ doSetProperty("password", password);
+ return this;
+ }
+ /**
+ * Specifies that all communication with MongoDB instances should use
+ * TLS. Supersedes the ssl option. Default: false.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tls the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder tls(boolean tls) {
+ doSetProperty("tls", tls);
+ return this;
+ }
+ /**
+ * Specifies that all communication with MongoDB instances should use
+ * TLS. Supersedes the ssl option. Default: false.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tls the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder tls(String tls) {
+ doSetProperty("tls", tls);
+ return this;
+ }
+ /**
+ * Specifies that the driver should allow invalid hostnames in the
+ * certificate for TLS connections. Supersedes
+ * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
+ * setting tlsAllowInvalidHostnames to true. Default: false.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tlsAllowInvalidHostnames the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder tlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
+ doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
+ return this;
+ }
+ /**
+ * Specifies that the driver should allow invalid hostnames in the
+ * certificate for TLS connections. Supersedes
+ * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
+ * setting tlsAllowInvalidHostnames to true. Default: false.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tlsAllowInvalidHostnames the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder tlsAllowInvalidHostnames(String tlsAllowInvalidHostnames) {
+ doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
+ return this;
+ }
+ /**
+ * Username for mongodb connection.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: security
+ *
+ * @param username the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointConsumerBuilder username(String username) {
+ doSetProperty("username", username);
+ return this;
+ }
}
/**
@@ -1339,74 +1408,6 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("srvServiceName", srvServiceName);
return this;
}
- /**
- * Specifies that all communication with MongoDB instances should use
- * TLS. Supersedes the ssl option. Default: false.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tls the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointConsumerBuilder tls(boolean tls) {
- doSetProperty("tls", tls);
- return this;
- }
- /**
- * Specifies that all communication with MongoDB instances should use
- * TLS. Supersedes the ssl option. Default: false.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tls the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointConsumerBuilder tls(String tls) {
- doSetProperty("tls", tls);
- return this;
- }
- /**
- * Specifies that the driver should allow invalid hostnames in the
- * certificate for TLS connections. Supersedes
- * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
- * setting tlsAllowInvalidHostnames to true. Default: false.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tlsAllowInvalidHostnames the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointConsumerBuilder tlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
- doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
- return this;
- }
- /**
- * Specifies that the driver should allow invalid hostnames in the
- * certificate for TLS connections. Supersedes
- * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
- * setting tlsAllowInvalidHostnames to true. Default: false.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tlsAllowInvalidHostnames the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointConsumerBuilder tlsAllowInvalidHostnames(String tlsAllowInvalidHostnames) {
- doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
- return this;
- }
/**
* Specifies the maximum amount of time, in milliseconds that a thread
* may wait for a connection to become available. Default: 120000 (120
@@ -1776,6 +1777,74 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("password", password);
return this;
}
+ /**
+ * Specifies that all communication with MongoDB instances should use
+ * TLS. Supersedes the ssl option. Default: false.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tls the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointProducerBuilder tls(boolean tls) {
+ doSetProperty("tls", tls);
+ return this;
+ }
+ /**
+ * Specifies that all communication with MongoDB instances should use
+ * TLS. Supersedes the ssl option. Default: false.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tls the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointProducerBuilder tls(String tls) {
+ doSetProperty("tls", tls);
+ return this;
+ }
+ /**
+ * Specifies that the driver should allow invalid hostnames in the
+ * certificate for TLS connections. Supersedes
+ * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
+ * setting tlsAllowInvalidHostnames to true. Default: false.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tlsAllowInvalidHostnames the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointProducerBuilder tlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
+ doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
+ return this;
+ }
+ /**
+ * Specifies that the driver should allow invalid hostnames in the
+ * certificate for TLS connections. Supersedes
+ * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
+ * setting tlsAllowInvalidHostnames to true. Default: false.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tlsAllowInvalidHostnames the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointProducerBuilder tlsAllowInvalidHostnames(String tlsAllowInvalidHostnames) {
+ doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
+ return this;
+ }
/**
* Username for mongodb connection.
*
@@ -2583,74 +2652,6 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("srvServiceName", srvServiceName);
return this;
}
- /**
- * Specifies that all communication with MongoDB instances should use
- * TLS. Supersedes the ssl option. Default: false.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tls the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointProducerBuilder tls(boolean tls) {
- doSetProperty("tls", tls);
- return this;
- }
- /**
- * Specifies that all communication with MongoDB instances should use
- * TLS. Supersedes the ssl option. Default: false.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tls the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointProducerBuilder tls(String tls) {
- doSetProperty("tls", tls);
- return this;
- }
- /**
- * Specifies that the driver should allow invalid hostnames in the
- * certificate for TLS connections. Supersedes
- * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
- * setting tlsAllowInvalidHostnames to true. Default: false.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tlsAllowInvalidHostnames the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointProducerBuilder tlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
- doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
- return this;
- }
- /**
- * Specifies that the driver should allow invalid hostnames in the
- * certificate for TLS connections. Supersedes
- * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
- * setting tlsAllowInvalidHostnames to true. Default: false.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tlsAllowInvalidHostnames the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointProducerBuilder tlsAllowInvalidHostnames(String tlsAllowInvalidHostnames) {
- doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
- return this;
- }
/**
* Specifies the maximum amount of time, in milliseconds that a thread
* may wait for a connection to become available. Default: 120000 (120
@@ -3021,6 +3022,74 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("password", password);
return this;
}
+ /**
+ * Specifies that all communication with MongoDB instances should use
+ * TLS. Supersedes the ssl option. Default: false.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tls the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointBuilder tls(boolean tls) {
+ doSetProperty("tls", tls);
+ return this;
+ }
+ /**
+ * Specifies that all communication with MongoDB instances should use
+ * TLS. Supersedes the ssl option. Default: false.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tls the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointBuilder tls(String tls) {
+ doSetProperty("tls", tls);
+ return this;
+ }
+ /**
+ * Specifies that the driver should allow invalid hostnames in the
+ * certificate for TLS connections. Supersedes
+ * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
+ * setting tlsAllowInvalidHostnames to true. Default: false.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tlsAllowInvalidHostnames the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointBuilder tlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
+ doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
+ return this;
+ }
+ /**
+ * Specifies that the driver should allow invalid hostnames in the
+ * certificate for TLS connections. Supersedes
+ * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
+ * setting tlsAllowInvalidHostnames to true. Default: false.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param tlsAllowInvalidHostnames the value to set
+ * @return the dsl builder
+ */
+ default MongoDbEndpointBuilder tlsAllowInvalidHostnames(String tlsAllowInvalidHostnames) {
+ doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
+ return this;
+ }
/**
* Username for mongodb connection.
*
@@ -3785,74 +3854,6 @@ public interface MongoDbEndpointBuilderFactory {
doSetProperty("srvServiceName", srvServiceName);
return this;
}
- /**
- * Specifies that all communication with MongoDB instances should use
- * TLS. Supersedes the ssl option. Default: false.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tls the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointBuilder tls(boolean tls) {
- doSetProperty("tls", tls);
- return this;
- }
- /**
- * Specifies that all communication with MongoDB instances should use
- * TLS. Supersedes the ssl option. Default: false.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tls the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointBuilder tls(String tls) {
- doSetProperty("tls", tls);
- return this;
- }
- /**
- * Specifies that the driver should allow invalid hostnames in the
- * certificate for TLS connections. Supersedes
- * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
- * setting tlsAllowInvalidHostnames to true. Default: false.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tlsAllowInvalidHostnames the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointBuilder tlsAllowInvalidHostnames(boolean tlsAllowInvalidHostnames) {
- doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
- return this;
- }
- /**
- * Specifies that the driver should allow invalid hostnames in the
- * certificate for TLS connections. Supersedes
- * sslInvalidHostNameAllowed. Has the same effect as tlsInsecure by
- * setting tlsAllowInvalidHostnames to true. Default: false.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: advanced
- *
- * @param tlsAllowInvalidHostnames the value to set
- * @return the dsl builder
- */
- default AdvancedMongoDbEndpointBuilder tlsAllowInvalidHostnames(String tlsAllowInvalidHostnames) {
- doSetProperty("tlsAllowInvalidHostnames", tlsAllowInvalidHostnames);
- return this;
- }
/**
* Specifies the maximum amount of time, in milliseconds that a thread
* may wait for a connection to become available. Default: 120000 (120