This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 48a009301ce 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) (#17162)
48a009301ce is described below
commit 48a009301cef900944e96c39461a26419c57a374
Author: Claus Ibsen <[email protected]>
AuthorDate: Sun Feb 16 09:57:20 2025 +0000
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) (#17162)
---
.../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
