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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 76169e562ad Regen
76169e562ad is described below
commit 76169e562ad201b1b05f63dff3b2c957cb1575d9
Author: Claus Ibsen <[email protected]>
AuthorDate: Wed Jul 26 09:23:25 2023 +0200
Regen
---
.../catalog/components/azure-servicebus.json | 28 ++---
.../catalog/components/google-mail-stream.json | 66 ++++++-----
.../springboot/catalog/components/pulsar.json | 130 +++++++++++----------
.../src/main/docs/azure-servicebus.json | 14 +--
.../ServiceBusComponentConfiguration.java | 42 +++----
.../src/main/docs/google-mail.json | 7 ++
.../GoogleMailStreamComponentConfiguration.java | 13 +++
.../camel-pulsar-starter/src/main/docs/pulsar.json | 13 +++
.../springboot/PulsarComponentConfiguration.java | 26 +++++
9 files changed, 198 insertions(+), 141 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
index 153d12aeaaf..25817b26b90 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-servicebus.json
@@ -23,17 +23,17 @@
},
"componentProperties": {
"amqpRetryOptions": { "index": 0, "kind": "property", "displayName": "Amqp
Retry Options", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "com.azure.core.amqp.AmqpRetryOptions",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the retry options
for Service Bus clients. If not specified [...]
- "amqpTransportType": { "index": 1, "kind": "property", "displayName":
"Amqp Transport Type", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "com.azure.core.amqp.AmqpTransportType", "enum":
[ "Amqp", "AmqpWebSockets" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "AMQP", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": [...]
- "clientOptions": { "index": 2, "kind": "property", "displayName": "Client
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.util.ClientOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the ClientOptions
to be sent from the client built from this builder, [...]
+ "amqpTransportType": { "index": 1, "kind": "property", "displayName":
"Amqp Transport Type", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "com.azure.core.amqp.AmqpTransportType", "enum":
[ "Amqp", "AmqpWebSockets" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "AMQP", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": [...]
+ "clientOptions": { "index": 2, "kind": "property", "displayName": "Client
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.util.ClientOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the ClientOptions
to be sent from the client built from this builder, [...]
"configuration": { "index": 3, "kind": "property", "displayName":
"Configuration", "group": "common", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
- "proxyOptions": { "index": 4, "kind": "property", "displayName": "Proxy
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.ProxyOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a p [...]
+ "proxyOptions": { "index": 4, "kind": "property", "displayName": "Proxy
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.ProxyOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a p [...]
"serviceBusType": { "index": 5, "kind": "property", "displayName":
"Service Bus Type", "group": "common", "label": "common", "required": true,
"type": "object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusType", "enum": [
"queue", "topic" ], "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": "queue", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "c [...]
"bridgeErrorHandler": { "index": 6, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "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 occurred while the consumer is trying to pickup incoming
messages, or the likes, will now be proce [...]
"consumerOperation": { "index": 7, "kind": "property", "displayName":
"Consumer Operation", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusConsumerOperationDefinition",
"enum": [ "receiveMessages", "peekMessages" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "receiveMessages",
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusCon [...]
- "disableAutoComplete": { "index": 8, "kind": "property", "displayName":
"Disable Auto Complete", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Disables auto-complete
and auto-abandon of received message [...]
- "maxAutoLockRenewDuration": { "index": 9, "kind": "property",
"displayName": "Max Auto Lock Renew Duration", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"java.time.Duration", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "5m", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue au [...]
+ "disableAutoComplete": { "index": 8, "kind": "property", "displayName":
"Disable Auto Complete", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Disables auto-complete
and auto-abandon of received message [...]
+ "maxAutoLockRenewDuration": { "index": 9, "kind": "property",
"displayName": "Max Auto Lock Renew Duration", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"java.time.Duration", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "5m", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue au [...]
"peekNumMaxMessages": { "index": 10, "kind": "property", "displayName":
"Peek Num Max Messages", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Set the max number of
messages to be peeked during the peek operation." },
- "prefetchCount": { "index": 11, "kind": "property", "displayName":
"Prefetch Count", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} [...]
+ "prefetchCount": { "index": 11, "kind": "property", "displayName":
"Prefetch Count", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both PEEK_LOCK PEEK_LOCK and RECEIVE_AND_DELETE RECEI [...]
"receiverAsyncClient": { "index": 12, "kind": "property", "displayName":
"Receiver Async Client", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets th [...]
"serviceBusReceiveMode": { "index": 13, "kind": "property", "displayName":
"Service Bus Receive Mode", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEEK_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration", "con
[...]
"subQueue": { "index": 14, "kind": "property", "displayName": "Sub Queue",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "com.azure.messaging.servicebus.models.SubQueue", "enum": [ "NONE",
"DEAD_LETTER_QUEUE", "TRANSFER_DEAD_LETTER_QUEUE" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "descriptio [...]
@@ -46,7 +46,7 @@
"autowiredEnabled": { "index": 21, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
"connectionString": { "index": 22, "kind": "property", "displayName":
"Connection String", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the connection
string for a Service Bus namespace or a specific Service Bus [...]
"fullyQualifiedNamespace": { "index": 23, "kind": "property",
"displayName": "Fully Qualified Namespace", "group": "security", "label":
"security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Fully Qualified
Namespace of the service bus" },
- "tokenCredential": { "index": 24, "kind": "property", "displayName":
"Token Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.core.credential.TokenCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication, implemented [...]
+ "tokenCredential": { "index": 24, "kind": "property", "displayName":
"Token Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.core.credential.TokenCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication." }
},
"headers": {
"CamelAzureServiceBusApplicationProperties": { "index": 0, "kind":
"header", "displayName": "", "group": "common", "label": "common", "required":
false, "javaType": "Map<String, Object>", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
application properties (also known as custom properties) on messages sent and
received by the producer and consumer, respectively.", "constantName":
"org.apache.camel.component.azure.servicebus.Servi [...]
@@ -78,15 +78,15 @@
"properties": {
"topicOrQueueName": { "index": 0, "kind": "path", "displayName": "Topic Or
Queue Name", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Selected topic name or
the queue name, that is depending on serviceBusType config. For exampl [...]
"amqpRetryOptions": { "index": 1, "kind": "parameter", "displayName":
"Amqp Retry Options", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "com.azure.core.amqp.AmqpRetryOptions",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the retry options
for Service Bus clients. If not specifie [...]
- "amqpTransportType": { "index": 2, "kind": "parameter", "displayName":
"Amqp Transport Type", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "com.azure.core.amqp.AmqpTransportType", "enum":
[ "Amqp", "AmqpWebSockets" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "AMQP", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": [...]
- "clientOptions": { "index": 3, "kind": "parameter", "displayName": "Client
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.util.ClientOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the ClientOptions
to be sent from the client built from this builder [...]
- "proxyOptions": { "index": 4, "kind": "parameter", "displayName": "Proxy
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.ProxyOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a [...]
+ "amqpTransportType": { "index": 2, "kind": "parameter", "displayName":
"Amqp Transport Type", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "com.azure.core.amqp.AmqpTransportType", "enum":
[ "Amqp", "AmqpWebSockets" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "AMQP", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": [...]
+ "clientOptions": { "index": 3, "kind": "parameter", "displayName": "Client
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.util.ClientOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the ClientOptions
to be sent from the client built from this builder [...]
+ "proxyOptions": { "index": 4, "kind": "parameter", "displayName": "Proxy
Options", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "com.azure.core.amqp.ProxyOptions", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a [...]
"serviceBusType": { "index": 5, "kind": "parameter", "displayName":
"Service Bus Type", "group": "common", "label": "common", "required": true,
"type": "object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusType", "enum": [
"queue", "topic" ], "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": "queue", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": " [...]
"consumerOperation": { "index": 6, "kind": "parameter", "displayName":
"Consumer Operation", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.azure.servicebus.ServiceBusConsumerOperationDefinition",
"enum": [ "receiveMessages", "peekMessages" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "receiveMessages",
"configurationClass": "org.apache.camel.component.azure.servicebus.ServiceBusCo
[...]
- "disableAutoComplete": { "index": 7, "kind": "parameter", "displayName":
"Disable Auto Complete", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Disables auto-complete
and auto-abandon of received messag [...]
- "maxAutoLockRenewDuration": { "index": 8, "kind": "parameter",
"displayName": "Max Auto Lock Renew Duration", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"java.time.Duration", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "5m", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue a [...]
+ "disableAutoComplete": { "index": 7, "kind": "parameter", "displayName":
"Disable Auto Complete", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Disables auto-complete
and auto-abandon of received messag [...]
+ "maxAutoLockRenewDuration": { "index": 8, "kind": "parameter",
"displayName": "Max Auto Lock Renew Duration", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"java.time.Duration", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "5m", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the amount of time
to continue a [...]
"peekNumMaxMessages": { "index": 9, "kind": "parameter", "displayName":
"Peek Num Max Messages", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Set the max number of
messages to be peeked during the peek operation." },
- "prefetchCount": { "index": 10, "kind": "parameter", "displayName":
"Prefetch Count", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK [...]
+ "prefetchCount": { "index": 10, "kind": "parameter", "displayName":
"Prefetch Count", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both PEEK_LOCK PEEK_LOCK and RECEIVE_AND_DELETE RECE [...]
"receiverAsyncClient": { "index": 11, "kind": "parameter", "displayName":
"Receiver Async Client", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets t [...]
"serviceBusReceiveMode": { "index": 12, "kind": "parameter",
"displayName": "Service Bus Receive Mode", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEEK_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration", "co [...]
"subQueue": { "index": 13, "kind": "parameter", "displayName": "Sub
Queue", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.servicebus.models.SubQueue", "enum":
[ "NONE", "DEAD_LETTER_QUEUE", "TRANSFER_DEAD_LETTER_QUEUE" ], "deprecated":
false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "descripti [...]
@@ -101,6 +101,6 @@
"lazyStartProducer": { "index": 22, "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 [...]
"connectionString": { "index": 23, "kind": "parameter", "displayName":
"Connection String", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the connection
string for a Service Bus namespace or a specific Service Bus [...]
"fullyQualifiedNamespace": { "index": 24, "kind": "parameter",
"displayName": "Fully Qualified Namespace", "group": "security", "label":
"security", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Fully Qualified
Namespace of the service bus" },
- "tokenCredential": { "index": 25, "kind": "parameter", "displayName":
"Token Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.core.credential.TokenCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication, implemente [...]
+ "tokenCredential": { "index": 25, "kind": "parameter", "displayName":
"Token Credential", "group": "security", "label": "security", "required":
false, "type": "object", "javaType":
"com.azure.core.credential.TokenCredential", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "A TokenCredential for
Azure AD authentication." }
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/google-mail-stream.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/google-mail-stream.json
index b15849a64c9..727eddbfa8d 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/google-mail-stream.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/google-mail-stream.json
@@ -30,14 +30,15 @@
"markAsRead": { "index": 5, "kind": "property", "displayName": "Mark As
Read", "group": "consumer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Mark the message as read
once it has been consumed" },
"maxResults": { "index": 6, "kind": "property", "displayName": "Max
Results", "group": "consumer", "label": "", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Max results to be
returned" },
"query": { "index": 7, "kind": "property", "displayName": "Query",
"group": "consumer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "is:unread", "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "The query to execute on
gmail box" },
- "scopes": { "index": 8, "kind": "property", "displayName": "Scopes",
"group": "consumer", "label": "", "required": false, "type": "array",
"javaType": "java.util.List<java.lang.String>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "GMail scopes" },
- "autowiredEnabled": { "index": 9, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
- "clientFactory": { "index": 10, "kind": "property", "displayName": "Client
Factory", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.google.mail.GoogleMailClientFactory", "deprecated":
false, "autowired": false, "secret": false, "description": "The client Factory"
},
- "configuration": { "index": 11, "kind": "property", "displayName":
"Configuration", "group": "advanced", "label": "advanced", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
configuration" },
- "accessToken": { "index": 12, "kind": "property", "displayName": "Access
Token", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 access token.
This typically expires after an hour so refreshToken is recom [...]
- "clientSecret": { "index": 13, "kind": "property", "displayName": "Client
Secret", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Client secret of the
mail application" },
- "refreshToken": { "index": 14, "kind": "property", "displayName": "Refresh
Token", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 refresh token.
Using this, the Google Calendar component can obtain a new [...]
- "serviceAccountKey": { "index": 15, "kind": "property", "displayName":
"Service Account Key", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Sets .json file with
credentials for Service account" }
+ "raw": { "index": 8, "kind": "property", "displayName": "Raw", "group":
"consumer", "label": "", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Whether to store the
entire email message in an RFC 2822 formatted and base64url encoded stri [...]
+ "scopes": { "index": 9, "kind": "property", "displayName": "Scopes",
"group": "consumer", "label": "", "required": false, "type": "array",
"javaType": "java.util.List<java.lang.String>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "GMail scopes" },
+ "autowiredEnabled": { "index": 10, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
+ "clientFactory": { "index": 11, "kind": "property", "displayName": "Client
Factory", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.google.mail.GoogleMailClientFactory", "deprecated":
false, "autowired": false, "secret": false, "description": "The client Factory"
},
+ "configuration": { "index": 12, "kind": "property", "displayName":
"Configuration", "group": "advanced", "label": "advanced", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
configuration" },
+ "accessToken": { "index": 13, "kind": "property", "displayName": "Access
Token", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 access token.
This typically expires after an hour so refreshToken is recom [...]
+ "clientSecret": { "index": 14, "kind": "property", "displayName": "Client
Secret", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Client secret of the
mail application" },
+ "refreshToken": { "index": 15, "kind": "property", "displayName": "Refresh
Token", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 refresh token.
Using this, the Google Calendar component can obtain a new [...]
+ "serviceAccountKey": { "index": 16, "kind": "property", "displayName":
"Service Account Key", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Sets .json file with
credentials for Service account" }
},
"headers": {
"CamelGoogleMailStreamTo": { "index": 0, "kind": "header", "displayName":
"", "group": "consumer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The recipient of the message", "constantName":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConstants#MAIL_TO"
},
@@ -56,29 +57,30 @@
"markAsRead": { "index": 5, "kind": "parameter", "displayName": "Mark As
Read", "group": "consumer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Mark the message as read
once it has been consumed" },
"maxResults": { "index": 6, "kind": "parameter", "displayName": "Max
Results", "group": "consumer", "label": "", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Max results to be
returned" },
"query": { "index": 7, "kind": "parameter", "displayName": "Query",
"group": "consumer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "is:unread", "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "The query to execute on
gmail box" },
- "scopes": { "index": 8, "kind": "parameter", "displayName": "Scopes",
"group": "consumer", "label": "", "required": false, "type": "array",
"javaType": "java.util.List<java.lang.String>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "GMail scopes" },
- "sendEmptyMessageWhenIdle": { "index": 9, "kind": "parameter",
"displayName": "Send Empty Message When Idle", "group": "consumer", "label":
"consumer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead." },
- "bridgeErrorHandler": { "index": 10, "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 occurred while the
consumer is trying to pickup incoming messages, or the li [...]
- "exceptionHandler": { "index": 11, "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": 12, "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." },
- "pollStrategy": { "index": 13, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
- "backoffErrorThreshold": { "index": 14, "kind": "parameter",
"displayName": "Backoff Error Threshold", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "description": "The
number of subsequent error polls (failed due some error) that should happen
before the backoffMultipler should kick-in." },
- "backoffIdleThreshold": { "index": 15, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
- "backoffMultiplier": { "index": 16, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
- "delay": { "index": 17, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
- "greedy": { "index": 18, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
- "initialDelay": { "index": 19, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
- "repeatCount": { "index": 20, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
- "runLoggingLevel": { "index": 21, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
- "scheduledExecutorService": { "index": 22, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
- "scheduler": { "index": 23, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
- "schedulerProperties": { "index": 24, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
- "startScheduler": { "index": 25, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
- "timeUnit": { "index": 26, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
- "useFixedDelay": { "index": 27, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." },
- "accessToken": { "index": 28, "kind": "parameter", "displayName": "Access
Token", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 access token.
This typically expires after an hour so refreshToken is reco [...]
- "clientSecret": { "index": 29, "kind": "parameter", "displayName": "Client
Secret", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Client secret of the
mail application" },
- "refreshToken": { "index": 30, "kind": "parameter", "displayName":
"Refresh Token", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 refresh token.
Using this, the Google Calendar component can obtain a ne [...]
- "serviceAccountKey": { "index": 31, "kind": "parameter", "displayName":
"Service Account Key", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Sets .json file with
credentials for Service account" }
+ "raw": { "index": 8, "kind": "parameter", "displayName": "Raw", "group":
"consumer", "label": "", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Whether to store the
entire email message in an RFC 2822 formatted and base64url encoded str [...]
+ "scopes": { "index": 9, "kind": "parameter", "displayName": "Scopes",
"group": "consumer", "label": "", "required": false, "type": "array",
"javaType": "java.util.List<java.lang.String>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "GMail scopes" },
+ "sendEmptyMessageWhenIdle": { "index": 10, "kind": "parameter",
"displayName": "Send Empty Message When Idle", "group": "consumer", "label":
"consumer", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead." },
+ "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 occurred while the
consumer is trying to pickup incoming messages, or the li [...]
+ "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." },
+ "pollStrategy": { "index": 14, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
+ "backoffErrorThreshold": { "index": 15, "kind": "parameter",
"displayName": "Backoff Error Threshold", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "description": "The
number of subsequent error polls (failed due some error) that should happen
before the backoffMultipler should kick-in." },
+ "backoffIdleThreshold": { "index": 16, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
+ "backoffMultiplier": { "index": 17, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
+ "delay": { "index": 18, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
+ "greedy": { "index": 19, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
+ "initialDelay": { "index": 20, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
+ "repeatCount": { "index": 21, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
+ "runLoggingLevel": { "index": 22, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
+ "scheduledExecutorService": { "index": 23, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
+ "scheduler": { "index": 24, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
+ "schedulerProperties": { "index": 25, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
+ "startScheduler": { "index": 26, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
+ "timeUnit": { "index": 27, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
+ "useFixedDelay": { "index": 28, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." },
+ "accessToken": { "index": 29, "kind": "parameter", "displayName": "Access
Token", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 access token.
This typically expires after an hour so refreshToken is reco [...]
+ "clientSecret": { "index": 30, "kind": "parameter", "displayName": "Client
Secret", "group": "security", "label": "security", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Client secret of the
mail application" },
+ "refreshToken": { "index": 31, "kind": "parameter", "displayName":
"Refresh Token", "group": "security", "label": "security", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "OAuth 2 refresh token.
Using this, the Google Calendar component can obtain a ne [...]
+ "serviceAccountKey": { "index": 32, "kind": "parameter", "displayName":
"Service Account Key", "group": "security", "label": "security", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.google.mail.stream.GoogleMailStreamConfiguration",
"configurationField": "configuration", "description": "Sets .json file with
credentials for Service account" }
}
}
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
index e3f6ffe3cb1..dfcf3763422 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
@@ -35,38 +35,40 @@
"consumerNamePrefix": { "index": 10, "kind": "property", "displayName":
"Consumer Name Prefix", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "cons",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Prefix to add to
consumer names when a SHARED or FAILOVER subscri [...]
"consumerQueueSize": { "index": 11, "kind": "property", "displayName":
"Consumer Queue Size", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Size of the consumer queue - defaults to 10" },
"deadLetterTopic": { "index": 12, "kind": "property", "displayName": "Dead
Letter Topic", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the topic where the messages which
fail maxRedeliverCount times will be sent. Note: if [...]
- "keySharedPolicy": { "index": 13, "kind": "property", "displayName": "Key
Shared Policy", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "AUTO_SPLIT",
"STICKY" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Policy to use by
consumer when using key-shared subscriptio [...]
- "maxRedeliverCount": { "index": 14, "kind": "property", "displayName":
"Max Redeliver Count", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Maximum number of times that a message will be
redelivered before being sent to the dead [...]
- "messageListener": { "index": 15, "kind": "property", "displayName":
"Message Listener", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Whether to use the
messageListener interface, or to receive messages using a separ [...]
- "negativeAckRedeliveryBackoff": { "index": 16, "kind": "property",
"displayName": "Negative Ack Redelivery Backoff", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "RedeliveryBackoff to use for negative [...]
- "negativeAckRedeliveryDelayMicros": { "index": 17, "kind": "property",
"displayName": "Negative Ack Redelivery Delay Micros", "group": "consumer",
"label": "consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Set the negative acknowledgement delay" },
- "numberOfConsumers": { "index": 18, "kind": "property", "displayName":
"Number Of Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Number of consumers - defaults to 1" },
- "numberOfConsumerThreads": { "index": 19, "kind": "property",
"displayName": "Number Of Consumer Threads", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Number of threads to
receive and handle messages when using a separate [...]
- "readCompacted": { "index": 20, "kind": "property", "displayName": "Read
Compacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Enable compacted topic reading." },
- "subscriptionInitialPosition": { "index": 21, "kind": "property",
"displayName": "Subscription Initial Position", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition",
"enum": [ "EARLIEST", "LATEST" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "conf [...]
- "subscriptionName": { "index": 22, "kind": "property", "displayName":
"Subscription Name", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "subs",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Name of the subscription
to use" },
- "subscriptionTopicsMode": { "index": 23, "kind": "property",
"displayName": "Subscription Topics Mode", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RegexSubscriptionMode", "enum": [
"PersistentOnly", "NonPersistentOnly", "AllTopics" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PersistentOnly",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"con [...]
- "subscriptionType": { "index": 24, "kind": "property", "displayName":
"Subscription Type", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER", "KEY_SHARED" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "EXCLUSIVE",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configur [...]
- "topicsPattern": { "index": 25, "kind": "property", "displayName": "Topics
Pattern", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Whether the topic is a pattern (regular
expression) that allows the consumer to subsc [...]
- "pulsarMessageReceiptFactory": { "index": 26, "kind": "property",
"displayName": "Pulsar Message Receipt Factory", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type": "object",
"javaType": "org.apache.camel.component.pulsar.PulsarMessageReceiptFactory",
"deprecated": false, "autowired": false, "secret": false, "description":
"Provide a factory to create an alternate implementation of
PulsarMessageReceipt." },
- "batcherBuilder": { "index": 27, "kind": "property", "displayName":
"Batcher Builder", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.BatcherBuilder",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"DEFAULT", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Control batching method used by the producer."
},
- "batchingEnabled": { "index": 28, "kind": "property", "displayName":
"Batching Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Control whether
automatic batching of messages is enabled for the producer." },
- "batchingMaxMessages": { "index": 29, "kind": "property", "displayName":
"Batching Max Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum size to batch messages." },
- "batchingMaxPublishDelayMicros": { "index": 30, "kind": "property",
"displayName": "Batching Max Publish Delay Micros", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum time period
within which the messages sent [...]
- "blockIfQueueFull": { "index": 31, "kind": "property", "displayName":
"Block If Queue Full", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Whether to block the
producing thread if pending messages queue is full or to [...]
- "chunkingEnabled": { "index": 32, "kind": "property", "displayName":
"Chunking Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Control whether chunking
of messages is enabled for the producer." },
- "compressionType": { "index": 33, "kind": "property", "displayName":
"Compression Type", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.CompressionType", "enum": [ "NONE", "LZ4",
"ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "descri [...]
- "initialSequenceId": { "index": 34, "kind": "property", "displayName":
"Initial Sequence Id", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
- "lazyStartProducer": { "index": 35, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "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 producer may otherwise fai [...]
- "maxPendingMessages": { "index": 36, "kind": "property", "displayName":
"Max Pending Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Size of the pending massages queue. When the
queue is full, by default, any fur [...]
- "maxPendingMessagesAcrossPartitions": { "index": 37, "kind": "property",
"displayName": "Max Pending Messages Across Partitions", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 50000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum number of
pending messages for pa [...]
- "messageRouter": { "index": 38, "kind": "property", "displayName":
"Message Router", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.MessageRouter",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Custom Message Router to use" },
- "messageRoutingMode": { "index": 39, "kind": "property", "displayName":
"Message Routing Mode", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition",
"RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "RoundRobinPartition",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
" [...]
- "producerName": { "index": 40, "kind": "property", "displayName":
"Producer Name", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the producer. If unset, lets Pulsar
select a unique identifier." },
- "sendTimeoutMs": { "index": 41, "kind": "property", "displayName": "Send
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Send timeout in milliseconds" },
- "autoConfiguration": { "index": 42, "kind": "property", "displayName":
"Auto Configuration", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.AutoConfiguration", "deprecated":
false, "autowired": false, "secret": false, "description": "The pulsar auto
configuration" },
- "autowiredEnabled": { "index": 43, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
- "pulsarClient": { "index": 44, "kind": "property", "displayName": "Pulsar
Client", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "org.apache.pulsar.client.api.PulsarClient",
"deprecated": false, "autowired": true, "secret": false, "description": "The
pulsar client" }
+ "enableRetry": { "index": 13, "kind": "property", "displayName": "Enable
Retry", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "To enable retry letter topic mode. The default
retry letter topic uses this format: topic [...]
+ "keySharedPolicy": { "index": 14, "kind": "property", "displayName": "Key
Shared Policy", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "AUTO_SPLIT",
"STICKY" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Policy to use by
consumer when using key-shared subscriptio [...]
+ "maxRedeliverCount": { "index": 15, "kind": "property", "displayName":
"Max Redeliver Count", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Maximum number of times that a message will be
redelivered before being sent to the dead [...]
+ "messageListener": { "index": 16, "kind": "property", "displayName":
"Message Listener", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Whether to use the
messageListener interface, or to receive messages using a separ [...]
+ "negativeAckRedeliveryBackoff": { "index": 17, "kind": "property",
"displayName": "Negative Ack Redelivery Backoff", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "RedeliveryBackoff to use for negative [...]
+ "negativeAckRedeliveryDelayMicros": { "index": 18, "kind": "property",
"displayName": "Negative Ack Redelivery Delay Micros", "group": "consumer",
"label": "consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Set the negative acknowledgement delay" },
+ "numberOfConsumers": { "index": 19, "kind": "property", "displayName":
"Number Of Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Number of consumers - defaults to 1" },
+ "numberOfConsumerThreads": { "index": 20, "kind": "property",
"displayName": "Number Of Consumer Threads", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Number of threads to
receive and handle messages when using a separate [...]
+ "readCompacted": { "index": 21, "kind": "property", "displayName": "Read
Compacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Enable compacted topic reading." },
+ "retryLetterTopic": { "index": 22, "kind": "property", "displayName":
"Retry Letter Topic", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the topic to use in retry mode. Note:
if not set, default topic name will be topicNam [...]
+ "subscriptionInitialPosition": { "index": 23, "kind": "property",
"displayName": "Subscription Initial Position", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition",
"enum": [ "EARLIEST", "LATEST" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "conf [...]
+ "subscriptionName": { "index": 24, "kind": "property", "displayName":
"Subscription Name", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "subs",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Name of the subscription
to use" },
+ "subscriptionTopicsMode": { "index": 25, "kind": "property",
"displayName": "Subscription Topics Mode", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RegexSubscriptionMode", "enum": [
"PersistentOnly", "NonPersistentOnly", "AllTopics" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PersistentOnly",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"con [...]
+ "subscriptionType": { "index": 26, "kind": "property", "displayName":
"Subscription Type", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER", "KEY_SHARED" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "EXCLUSIVE",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configur [...]
+ "topicsPattern": { "index": 27, "kind": "property", "displayName": "Topics
Pattern", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Whether the topic is a pattern (regular
expression) that allows the consumer to subsc [...]
+ "pulsarMessageReceiptFactory": { "index": 28, "kind": "property",
"displayName": "Pulsar Message Receipt Factory", "group": "consumer
(advanced)", "label": "consumer,advanced", "required": false, "type": "object",
"javaType": "org.apache.camel.component.pulsar.PulsarMessageReceiptFactory",
"deprecated": false, "autowired": false, "secret": false, "description":
"Provide a factory to create an alternate implementation of
PulsarMessageReceipt." },
+ "batcherBuilder": { "index": 29, "kind": "property", "displayName":
"Batcher Builder", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.BatcherBuilder",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"DEFAULT", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Control batching method used by the producer."
},
+ "batchingEnabled": { "index": 30, "kind": "property", "displayName":
"Batching Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Control whether
automatic batching of messages is enabled for the producer." },
+ "batchingMaxMessages": { "index": 31, "kind": "property", "displayName":
"Batching Max Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum size to batch messages." },
+ "batchingMaxPublishDelayMicros": { "index": 32, "kind": "property",
"displayName": "Batching Max Publish Delay Micros", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum time period
within which the messages sent [...]
+ "blockIfQueueFull": { "index": 33, "kind": "property", "displayName":
"Block If Queue Full", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Whether to block the
producing thread if pending messages queue is full or to [...]
+ "chunkingEnabled": { "index": 34, "kind": "property", "displayName":
"Chunking Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "Control whether chunking
of messages is enabled for the producer." },
+ "compressionType": { "index": 35, "kind": "property", "displayName":
"Compression Type", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.CompressionType", "enum": [ "NONE", "LZ4",
"ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "descri [...]
+ "initialSequenceId": { "index": 36, "kind": "property", "displayName":
"Initial Sequence Id", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
+ "lazyStartProducer": { "index": 37, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "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 producer may otherwise fai [...]
+ "maxPendingMessages": { "index": 38, "kind": "property", "displayName":
"Max Pending Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Size of the pending massages queue. When the
queue is full, by default, any fur [...]
+ "maxPendingMessagesAcrossPartitions": { "index": 39, "kind": "property",
"displayName": "Max Pending Messages Across Partitions", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 50000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum number of
pending messages for pa [...]
+ "messageRouter": { "index": 40, "kind": "property", "displayName":
"Message Router", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.MessageRouter",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Custom Message Router to use" },
+ "messageRoutingMode": { "index": 41, "kind": "property", "displayName":
"Message Routing Mode", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition",
"RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "RoundRobinPartition",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
" [...]
+ "producerName": { "index": 42, "kind": "property", "displayName":
"Producer Name", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the producer. If unset, lets Pulsar
select a unique identifier." },
+ "sendTimeoutMs": { "index": 43, "kind": "property", "displayName": "Send
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Send timeout in milliseconds" },
+ "autoConfiguration": { "index": 44, "kind": "property", "displayName":
"Auto Configuration", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.AutoConfiguration", "deprecated":
false, "autowired": false, "secret": false, "description": "The pulsar auto
configuration" },
+ "autowiredEnabled": { "index": 45, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
+ "pulsarClient": { "index": 46, "kind": "property", "displayName": "Pulsar
Client", "group": "advanced", "label": "advanced", "required": false, "type":
"object", "javaType": "org.apache.pulsar.client.api.PulsarClient",
"deprecated": false, "autowired": true, "secret": false, "description": "The
pulsar client" }
},
"headers": {
"properties": { "index": 0, "kind": "header", "displayName": "", "group":
"consumer", "label": "consumer", "required": false, "javaType": "Map<String,
String>", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The properties attached to the message.",
"constantName":
"org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders#PROPERTIES"
},
@@ -101,36 +103,38 @@
"consumerNamePrefix": { "index": 12, "kind": "parameter", "displayName":
"Consumer Name Prefix", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "cons",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Prefix to add to
consumer names when a SHARED or FAILOVER [...]
"consumerQueueSize": { "index": 13, "kind": "parameter", "displayName":
"Consumer Queue Size", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 10, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Size of the consumer queue - defaults to
10" },
"deadLetterTopic": { "index": 14, "kind": "parameter", "displayName":
"Dead Letter Topic", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the topic where the messages
which fail maxRedeliverCount times will be sent. No [...]
- "keySharedPolicy": { "index": 15, "kind": "parameter", "displayName": "Key
Shared Policy", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "AUTO_SPLIT",
"STICKY" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Policy to use by
consumer when using key-shared subs [...]
- "maxRedeliverCount": { "index": 16, "kind": "parameter", "displayName":
"Max Redeliver Count", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Maximum number of times that a message
will be redelivered before being sent to th [...]
- "messageListener": { "index": 17, "kind": "parameter", "displayName":
"Message Listener", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Whether to use the
messageListener interface, or to receive messages using [...]
- "negativeAckRedeliveryBackoff": { "index": 18, "kind": "parameter",
"displayName": "Negative Ack Redelivery Backoff", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "RedeliveryBackoff to use for ne [...]
- "negativeAckRedeliveryDelayMicros": { "index": 19, "kind": "parameter",
"displayName": "Negative Ack Redelivery Delay Micros", "group": "consumer",
"label": "consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Set the negative acknowledgement delay"
},
- "numberOfConsumers": { "index": 20, "kind": "parameter", "displayName":
"Number Of Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Number of consumers - defaults to 1" },
- "numberOfConsumerThreads": { "index": 21, "kind": "parameter",
"displayName": "Number Of Consumer Threads", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Number of threads
to receive and handle messages when using a se [...]
- "readCompacted": { "index": 22, "kind": "parameter", "displayName": "Read
Compacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Enable compacted topic reading." },
- "subscriptionInitialPosition": { "index": 23, "kind": "parameter",
"displayName": "Subscription Initial Position", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition",
"enum": [ "EARLIEST", "LATEST" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "con [...]
- "subscriptionName": { "index": 24, "kind": "parameter", "displayName":
"Subscription Name", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "subs",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Name of the
subscription to use" },
- "subscriptionTopicsMode": { "index": 25, "kind": "parameter",
"displayName": "Subscription Topics Mode", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RegexSubscriptionMode", "enum": [
"PersistentOnly", "NonPersistentOnly", "AllTopics" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PersistentOnly",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"co [...]
- "subscriptionType": { "index": 26, "kind": "parameter", "displayName":
"Subscription Type", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER", "KEY_SHARED" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "EXCLUSIVE",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configu [...]
- "topicsPattern": { "index": 27, "kind": "parameter", "displayName":
"Topics Pattern", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Whether the topic is a pattern (regular
expression) that allows the consumer t [...]
- "bridgeErrorHandler": { "index": 28, "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 occurred while the
consumer is trying to pickup incoming messages, or the li [...]
- "exceptionHandler": { "index": 29, "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": 30, "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." },
- "batcherBuilder": { "index": 31, "kind": "parameter", "displayName":
"Batcher Builder", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.BatcherBuilder",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"DEFAULT", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Control batching method used by the p
[...]
- "batchingEnabled": { "index": 32, "kind": "parameter", "displayName":
"Batching Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Control whether
automatic batching of messages is enabled for the producer." },
- "batchingMaxMessages": { "index": 33, "kind": "parameter", "displayName":
"Batching Max Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum size to batch messages." },
- "batchingMaxPublishDelayMicros": { "index": 34, "kind": "parameter",
"displayName": "Batching Max Publish Delay Micros", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum time
period within which the messag [...]
- "blockIfQueueFull": { "index": 35, "kind": "parameter", "displayName":
"Block If Queue Full", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Whether to block
the producing thread if pending messages queue is ful [...]
- "chunkingEnabled": { "index": 36, "kind": "parameter", "displayName":
"Chunking Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Control whether
chunking of messages is enabled for the producer." },
- "compressionType": { "index": 37, "kind": "parameter", "displayName":
"Compression Type", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.CompressionType", "enum": [ "NONE", "LZ4",
"ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", [...]
- "initialSequenceId": { "index": 38, "kind": "parameter", "displayName":
"Initial Sequence Id", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
- "maxPendingMessages": { "index": 39, "kind": "parameter", "displayName":
"Max Pending Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Size of the pending massages queue. When
the queue is full, by default, [...]
- "maxPendingMessagesAcrossPartitions": { "index": 40, "kind": "parameter",
"displayName": "Max Pending Messages Across Partitions", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 50000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum number
of pending messages [...]
- "messageRouter": { "index": 41, "kind": "parameter", "displayName":
"Message Router", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.MessageRouter",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Custom Message Router to use" },
- "messageRoutingMode": { "index": 42, "kind": "parameter", "displayName":
"Message Routing Mode", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition",
"RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "RoundRobinPartition",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
[...]
- "producerName": { "index": 43, "kind": "parameter", "displayName":
"Producer Name", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the producer. If unset, lets
Pulsar select a unique identifier." },
- "sendTimeoutMs": { "index": 44, "kind": "parameter", "displayName": "Send
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Send timeout in milliseconds" },
- "lazyStartProducer": { "index": 45, "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 [...]
+ "enableRetry": { "index": 15, "kind": "parameter", "displayName": "Enable
Retry", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "To enable retry letter topic mode. The
default retry letter topic uses this format [...]
+ "keySharedPolicy": { "index": 16, "kind": "parameter", "displayName": "Key
Shared Policy", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "enum": [ "AUTO_SPLIT",
"STICKY" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Policy to use by
consumer when using key-shared subs [...]
+ "maxRedeliverCount": { "index": 17, "kind": "parameter", "displayName":
"Max Redeliver Count", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Maximum number of times that a message
will be redelivered before being sent to th [...]
+ "messageListener": { "index": 18, "kind": "parameter", "displayName":
"Message Listener", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Whether to use the
messageListener interface, or to receive messages using [...]
+ "negativeAckRedeliveryBackoff": { "index": 19, "kind": "parameter",
"displayName": "Negative Ack Redelivery Backoff", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "RedeliveryBackoff to use for ne [...]
+ "negativeAckRedeliveryDelayMicros": { "index": 20, "kind": "parameter",
"displayName": "Negative Ack Redelivery Delay Micros", "group": "consumer",
"label": "consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Set the negative acknowledgement delay"
},
+ "numberOfConsumers": { "index": 21, "kind": "parameter", "displayName":
"Number Of Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Number of consumers - defaults to 1" },
+ "numberOfConsumerThreads": { "index": 22, "kind": "parameter",
"displayName": "Number Of Consumer Threads", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Number of threads
to receive and handle messages when using a se [...]
+ "readCompacted": { "index": 23, "kind": "parameter", "displayName": "Read
Compacted", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Enable compacted topic reading." },
+ "retryLetterTopic": { "index": 24, "kind": "parameter", "displayName":
"Retry Letter Topic", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the topic to use in retry mode.
Note: if not set, default topic name will be t [...]
+ "subscriptionInitialPosition": { "index": 25, "kind": "parameter",
"displayName": "Subscription Initial Position", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition",
"enum": [ "EARLIEST", "LATEST" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "con [...]
+ "subscriptionName": { "index": 26, "kind": "parameter", "displayName":
"Subscription Name", "group": "consumer", "label": "consumer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "subs",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Name of the
subscription to use" },
+ "subscriptionTopicsMode": { "index": 27, "kind": "parameter",
"displayName": "Subscription Topics Mode", "group": "consumer", "label":
"consumer", "required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RegexSubscriptionMode", "enum": [
"PersistentOnly", "NonPersistentOnly", "AllTopics" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "PersistentOnly",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"co [...]
+ "subscriptionType": { "index": 28, "kind": "parameter", "displayName":
"Subscription Type", "group": "consumer", "label": "consumer", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.pulsar.utils.consumers.SubscriptionType", "enum": [
"EXCLUSIVE", "SHARED", "FAILOVER", "KEY_SHARED" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "EXCLUSIVE",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configu [...]
+ "topicsPattern": { "index": 29, "kind": "parameter", "displayName":
"Topics Pattern", "group": "consumer", "label": "consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Whether the topic is a pattern (regular
expression) that allows the consumer t [...]
+ "bridgeErrorHandler": { "index": 30, "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 occurred while the
consumer is trying to pickup incoming messages, or the li [...]
+ "exceptionHandler": { "index": 31, "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": 32, "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." },
+ "batcherBuilder": { "index": 33, "kind": "parameter", "displayName":
"Batcher Builder", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.BatcherBuilder",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"DEFAULT", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Control batching method used by the p
[...]
+ "batchingEnabled": { "index": 34, "kind": "parameter", "displayName":
"Batching Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Control whether
automatic batching of messages is enabled for the producer." },
+ "batchingMaxMessages": { "index": 35, "kind": "parameter", "displayName":
"Batching Max Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum size to batch messages." },
+ "batchingMaxPublishDelayMicros": { "index": 36, "kind": "parameter",
"displayName": "Batching Max Publish Delay Micros", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum time
period within which the messag [...]
+ "blockIfQueueFull": { "index": 37, "kind": "parameter", "displayName":
"Block If Queue Full", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Whether to block
the producing thread if pending messages queue is ful [...]
+ "chunkingEnabled": { "index": 38, "kind": "parameter", "displayName":
"Chunking Enabled", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "Control whether
chunking of messages is enabled for the producer." },
+ "compressionType": { "index": 39, "kind": "parameter", "displayName":
"Compression Type", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.CompressionType", "enum": [ "NONE", "LZ4",
"ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", [...]
+ "initialSequenceId": { "index": 40, "kind": "parameter", "displayName":
"Initial Sequence Id", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
+ "maxPendingMessages": { "index": 41, "kind": "parameter", "displayName":
"Max Pending Messages", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Size of the pending massages queue. When
the queue is full, by default, [...]
+ "maxPendingMessagesAcrossPartitions": { "index": 42, "kind": "parameter",
"displayName": "Max Pending Messages Across Partitions", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 50000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum number
of pending messages [...]
+ "messageRouter": { "index": 43, "kind": "parameter", "displayName":
"Message Router", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "org.apache.pulsar.client.api.MessageRouter",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Custom Message Router to use" },
+ "messageRoutingMode": { "index": 44, "kind": "parameter", "displayName":
"Message Routing Mode", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType":
"org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition",
"RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "RoundRobinPartition",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
[...]
+ "producerName": { "index": 45, "kind": "parameter", "displayName":
"Producer Name", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the producer. If unset, lets
Pulsar select a unique identifier." },
+ "sendTimeoutMs": { "index": 46, "kind": "parameter", "displayName": "Send
Timeout Ms", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Send timeout in milliseconds" },
+ "lazyStartProducer": { "index": 47, "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 [...]
}
}
diff --git
a/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
b/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
index 9c710a5b225..17a85494a5b 100644
---
a/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
+++
b/components-starter/camel-azure-servicebus-starter/src/main/docs/azure-servicebus.json
@@ -22,7 +22,7 @@
{
"name": "camel.component.azure-servicebus.amqp-transport-type",
"type": "com.azure.core.amqp.AmqpTransportType",
- "description": "Sets the transport type by which all the communication
with Azure Service Bus occurs. Default value is AmqpTransportType#AMQP.",
+ "description": "Sets the transport type by which all the communication
with Azure Service Bus occurs. Default value is AMQP.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
@@ -42,7 +42,7 @@
{
"name": "camel.component.azure-servicebus.client-options",
"type": "com.azure.core.util.ClientOptions",
- "description": "Sets the ClientOptions to be sent from the client built
from this builder, enabling customization of certain properties, as well as
support the addition of custom header information. Refer to the ClientOptions
documentation for more information. The option is a
com.azure.core.util.ClientOptions type.",
+ "description": "Sets the ClientOptions to be sent from the client built
from this builder, enabling customization of certain properties, as well as
support the addition of custom header information. The option is a
com.azure.core.util.ClientOptions type.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
@@ -71,7 +71,7 @@
{
"name": "camel.component.azure-servicebus.disable-auto-complete",
"type": "java.lang.Boolean",
- "description": "Disables auto-complete and auto-abandon of received
messages. By default, a successfully processed message is {link
ServiceBusReceiverAsyncClient#complete(ServiceBusReceivedMessage) completed}.
If an error happens when the message is processed, it is {link
ServiceBusReceiverAsyncClient#abandon(ServiceBusReceivedMessage) abandoned}.",
+ "description": "Disables auto-complete and auto-abandon of received
messages. By default, a successfully processed message is completed. If an
error happens when the message is abandoned.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration",
"defaultValue": false
},
@@ -97,7 +97,7 @@
{
"name": "camel.component.azure-servicebus.max-auto-lock-renew-duration",
"type": "java.time.Duration",
- "description": "Sets the amount of time to continue auto-renewing the
lock. Setting Duration#ZERO or null disables auto-renewal. For {link
ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} mode, auto-renewal
is disabled. The option is a java.time.Duration type.",
+ "description": "Sets the amount of time to continue auto-renewing the
lock. Setting ZERO disables auto-renewal. For ServiceBus receive mode
(RECEIVE_AND_DELETE RECEIVE_AND_DELETE), auto-renewal is disabled. The option
is a java.time.Duration type.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
@@ -109,7 +109,7 @@
{
"name": "camel.component.azure-servicebus.prefetch-count",
"type": "java.lang.Integer",
- "description": "Sets the prefetch count of the receiver. For both {link
ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and {link
ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} modes the default
value is 1. Prefetch speeds up the message flow by aiming to have a message
readily available for local retrieval when and before the application asks for
one using ServiceBusReceiverAsyncClient#receiveMessages(). Setting a non-zero
value will prefetch that number of messages. Sett [...]
+ "description": "Sets the prefetch count of the receiver. For both
PEEK_LOCK PEEK_LOCK and RECEIVE_AND_DELETE RECEIVE_AND_DELETE receive modes the
default value is 1. Prefetch speeds up the message flow by aiming to have a
message readily available for local retrieval when and before the application
asks for one using receive message. Setting a non-zero value will prefetch that
number of messages. Setting the value to zero turns prefetch off.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
@@ -121,7 +121,7 @@
{
"name": "camel.component.azure-servicebus.proxy-options",
"type": "com.azure.core.amqp.ProxyOptions",
- "description": "Sets the proxy configuration to use for
ServiceBusSenderAsyncClient. When a proxy is configured,
AmqpTransportType#AMQP_WEB_SOCKETS must be used for the transport type. The
option is a com.azure.core.amqp.ProxyOptions type.",
+ "description": "Sets the proxy configuration to use for
ServiceBusSenderAsyncClient. When a proxy is configured, AMQP_WEB_SOCKETS must
be used for the transport type. The option is a
com.azure.core.amqp.ProxyOptions type.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
},
{
@@ -175,7 +175,7 @@
{
"name": "camel.component.azure-servicebus.token-credential",
"type": "com.azure.core.credential.TokenCredential",
- "description": "A TokenCredential for Azure AD authentication,
implemented in com.azure.identity. The option is a
com.azure.core.credential.TokenCredential type.",
+ "description": "A TokenCredential for Azure AD authentication. The
option is a com.azure.core.credential.TokenCredential type.",
"sourceType":
"org.apache.camel.component.azure.servicebus.springboot.ServiceBusComponentConfiguration"
}
],
diff --git
a/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
b/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
index c4b56cb8a13..d88228306f3 100644
---
a/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
+++
b/components-starter/camel-azure-servicebus-starter/src/main/java/org/apache/camel/component/azure/servicebus/springboot/ServiceBusComponentConfiguration.java
@@ -59,14 +59,13 @@ public class ServiceBusComponentConfiguration
private AmqpRetryOptions amqpRetryOptions;
/**
* Sets the transport type by which all the communication with Azure
Service
- * Bus occurs. Default value is AmqpTransportType#AMQP.
+ * Bus occurs. Default value is AMQP.
*/
private AmqpTransportType amqpTransportType = AmqpTransportType.AMQP;
/**
* Sets the ClientOptions to be sent from the client built from this
* builder, enabling customization of certain properties, as well as
support
- * the addition of custom header information. Refer to the ClientOptions
- * documentation for more information. The option is a
+ * the addition of custom header information. The option is a
* com.azure.core.util.ClientOptions type.
*/
private ClientOptions clientOptions;
@@ -77,9 +76,8 @@ public class ServiceBusComponentConfiguration
private ServiceBusConfiguration configuration;
/**
* Sets the proxy configuration to use for ServiceBusSenderAsyncClient.
When
- * a proxy is configured, AmqpTransportType#AMQP_WEB_SOCKETS must be used
- * for the transport type. The option is a com.azure.core.amqp.ProxyOptions
- * type.
+ * a proxy is configured, AMQP_WEB_SOCKETS must be used for the transport
+ * type. The option is a com.azure.core.amqp.ProxyOptions type.
*/
private ProxyOptions proxyOptions;
/**
@@ -102,18 +100,15 @@ public class ServiceBusComponentConfiguration
private ServiceBusConsumerOperationDefinition consumerOperation =
ServiceBusConsumerOperationDefinition.receiveMessages;
/**
* Disables auto-complete and auto-abandon of received messages. By
default,
- * a successfully processed message is {link
- * ServiceBusReceiverAsyncClient#complete(ServiceBusReceivedMessage)
- * completed}. If an error happens when the message is processed, it is
- * {link ServiceBusReceiverAsyncClient#abandon(ServiceBusReceivedMessage)
- * abandoned}.
+ * a successfully processed message is completed. If an error happens when
+ * the message is abandoned.
*/
private Boolean disableAutoComplete = false;
/**
- * Sets the amount of time to continue auto-renewing the lock. Setting
- * Duration#ZERO or null disables auto-renewal. For {link
- * ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} mode,
- * auto-renewal is disabled. The option is a java.time.Duration type.
+ * Sets the amount of time to continue auto-renewing the lock. Setting ZERO
+ * disables auto-renewal. For ServiceBus receive mode (RECEIVE_AND_DELETE
+ * RECEIVE_AND_DELETE), auto-renewal is disabled. The option is a
+ * java.time.Duration type.
*/
private Duration maxAutoLockRenewDuration;
/**
@@ -121,14 +116,12 @@ public class ServiceBusComponentConfiguration
*/
private Integer peekNumMaxMessages;
/**
- * Sets the prefetch count of the receiver. For both {link
- * ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and {link
- * ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} modes the
- * default value is 1. Prefetch speeds up the message flow by aiming to
have
- * a message readily available for local retrieval when and before the
- * application asks for one using
- * ServiceBusReceiverAsyncClient#receiveMessages(). Setting a non-zero
value
- * will prefetch that number of messages. Setting the value to zero turns
+ * Sets the prefetch count of the receiver. For both PEEK_LOCK PEEK_LOCK
and
+ * RECEIVE_AND_DELETE RECEIVE_AND_DELETE receive modes the default value is
+ * 1. Prefetch speeds up the message flow by aiming to have a message
+ * readily available for local retrieval when and before the application
+ * asks for one using receive message. Setting a non-zero value will
+ * prefetch that number of messages. Setting the value to zero turns
* prefetch off.
*/
private Integer prefetchCount;
@@ -202,8 +195,7 @@ public class ServiceBusComponentConfiguration
*/
private String fullyQualifiedNamespace;
/**
- * A TokenCredential for Azure AD authentication, implemented in
- * com.azure.identity. The option is a
+ * A TokenCredential for Azure AD authentication. The option is a
* com.azure.core.credential.TokenCredential type.
*/
private TokenCredential tokenCredential;
diff --git
a/components-starter/camel-google-mail-starter/src/main/docs/google-mail.json
b/components-starter/camel-google-mail-starter/src/main/docs/google-mail.json
index e4ebff978ca..00f650a6414 100644
---
a/components-starter/camel-google-mail-starter/src/main/docs/google-mail.json
+++
b/components-starter/camel-google-mail-starter/src/main/docs/google-mail.json
@@ -118,6 +118,13 @@
"sourceType":
"org.apache.camel.component.google.mail.stream.springboot.GoogleMailStreamComponentConfiguration",
"defaultValue": "is:unread"
},
+ {
+ "name": "camel.component.google-mail-stream.raw",
+ "type": "java.lang.Boolean",
+ "description": "Whether to store the entire email message in an RFC 2822
formatted and base64url encoded string (in JSon format), in the Camel message
body.",
+ "sourceType":
"org.apache.camel.component.google.mail.stream.springboot.GoogleMailStreamComponentConfiguration",
+ "defaultValue": false
+ },
{
"name": "camel.component.google-mail-stream.refresh-token",
"type": "java.lang.String",
diff --git
a/components-starter/camel-google-mail-starter/src/main/java/org/apache/camel/component/google/mail/stream/springboot/GoogleMailStreamComponentConfiguration.java
b/components-starter/camel-google-mail-starter/src/main/java/org/apache/camel/component/google/mail/stream/springboot/GoogleMailStreamComponentConfiguration.java
index c53b1f85f91..c3f98dded37 100644
---
a/components-starter/camel-google-mail-starter/src/main/java/org/apache/camel/component/google/mail/stream/springboot/GoogleMailStreamComponentConfiguration.java
+++
b/components-starter/camel-google-mail-starter/src/main/java/org/apache/camel/component/google/mail/stream/springboot/GoogleMailStreamComponentConfiguration.java
@@ -74,6 +74,11 @@ public class GoogleMailStreamComponentConfiguration
* The query to execute on gmail box
*/
private String query = "is:unread";
+ /**
+ * Whether to store the entire email message in an RFC 2822 formatted and
+ * base64url encoded string (in JSon format), in the Camel message body.
+ */
+ private Boolean raw = false;
/**
* GMail scopes
*/
@@ -181,6 +186,14 @@ public class GoogleMailStreamComponentConfiguration
this.query = query;
}
+ public Boolean getRaw() {
+ return raw;
+ }
+
+ public void setRaw(Boolean raw) {
+ this.raw = raw;
+ }
+
public List<String> getScopes() {
return scopes;
}
diff --git a/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
b/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
index 7ad354456ac..46f6c12d9e3 100644
--- a/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
+++ b/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
@@ -157,6 +157,13 @@
"description": "Name of the topic where the messages which fail
maxRedeliverCount times will be sent. Note: if not set, default topic name will
be topicName-subscriptionName-DLQ",
"sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration"
},
+ {
+ "name": "camel.component.pulsar.enable-retry",
+ "type": "java.lang.Boolean",
+ "description": "To enable retry letter topic mode. The default retry
letter topic uses this format: topicname-subscriptionname-RETRY",
+ "sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
+ "defaultValue": false
+ },
{
"name": "camel.component.pulsar.enabled",
"type": "java.lang.Boolean",
@@ -267,6 +274,12 @@
"sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.pulsar.retry-letter-topic",
+ "type": "java.lang.String",
+ "description": "Name of the topic to use in retry mode. Note: if not
set, default topic name will be topicName-subscriptionName-RETRY",
+ "sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration"
+ },
{
"name": "camel.component.pulsar.send-timeout-ms",
"type": "java.lang.Integer",
diff --git
a/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
b/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
index c301ef0fcde..f7d91fc11e3 100644
---
a/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
+++
b/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
@@ -118,6 +118,11 @@ public class PulsarComponentConfiguration
* topicName-subscriptionName-DLQ
*/
private String deadLetterTopic;
+ /**
+ * To enable retry letter topic mode. The default retry letter topic uses
+ * this format: topicname-subscriptionname-RETRY
+ */
+ private Boolean enableRetry = false;
/**
* Policy to use by consumer when using key-shared subscription type.
*/
@@ -155,6 +160,11 @@ public class PulsarComponentConfiguration
* Enable compacted topic reading.
*/
private Boolean readCompacted = false;
+ /**
+ * Name of the topic to use in retry mode. Note: if not set, default topic
+ * name will be topicName-subscriptionName-RETRY
+ */
+ private String retryLetterTopic;
/**
* Control the initial position in the topic of a newly created
* subscription. Default is latest message.
@@ -389,6 +399,14 @@ public class PulsarComponentConfiguration
this.deadLetterTopic = deadLetterTopic;
}
+ public Boolean getEnableRetry() {
+ return enableRetry;
+ }
+
+ public void setEnableRetry(Boolean enableRetry) {
+ this.enableRetry = enableRetry;
+ }
+
public String getKeySharedPolicy() {
return keySharedPolicy;
}
@@ -455,6 +473,14 @@ public class PulsarComponentConfiguration
this.readCompacted = readCompacted;
}
+ public String getRetryLetterTopic() {
+ return retryLetterTopic;
+ }
+
+ public void setRetryLetterTopic(String retryLetterTopic) {
+ this.retryLetterTopic = retryLetterTopic;
+ }
+
public SubscriptionInitialPosition getSubscriptionInitialPosition() {
return subscriptionInitialPosition;
}
