This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new fd5fe88 [create-pull-request] automated change
fd5fe88 is described below
commit fd5fe88e0b619e1908cd32cb0edb63a06770d9af
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jun 15 03:46:13 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-rabbitmq-source.json | 14 ++++++++++++++
.../src/generated/resources/camel-rabbitmq-source.json | 14 ++++++++++++++
.../main/docs/camel-rabbitmq-kafka-source-connector.adoc | 4 +++-
.../rabbitmq/CamelRabbitmqSourceConnectorConfig.java | 8 ++++++++
.../connectors/camel-rabbitmq-kafka-source-connector.adoc | 8 +++-----
5 files changed, 42 insertions(+), 6 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-rabbitmq-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-rabbitmq-source.json
index fa59ee0..3fe51b0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-rabbitmq-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-rabbitmq-source.json
@@ -232,6 +232,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.recoverFromDeclareException": {
+ "name":
"camel.source.endpoint.recoverFromDeclareException",
+ "description": "Decides whether an exception during
declaration of exchanges or queues is recoverable or not. If the option is
false, camel will throw an exception when starting the consumer, which will
interrupt application startup (e.g. in the case when the exchange \/ queue is
already declared in RabbitMQ and has incompatible configuration). If set to
true, the consumer will try to reconnect periodically.",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.reQueue": {
"name": "camel.source.endpoint.reQueue",
"description": "This is used by the consumer to control
rejection of the message. When the consumer is complete processing the
exchange, and if the exchange failed, then the consumer is going to reject the
message from the RabbitMQ broker. If the header CamelRabbitmqRequeue is present
then the value of the header will be used, otherwise this endpoint value is
used as fallback. If the value is false (by default) then the message is
discarded\/dead-lettered. If the value is true, then t [...]
@@ -542,6 +549,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.rabbitmq.recoverFromDeclareException": {
+ "name":
"camel.component.rabbitmq.recoverFromDeclareException",
+ "description": "Decides whether an exception during
declaration of exchanges or queues is recoverable or not. If the option is
false, camel will throw an exception when starting the consumer, which will
interrupt application startup (e.g. in the case when the exchange \/ queue is
already declared in RabbitMQ and has incompatible configuration). If set to
true, the consumer will try to reconnect periodically.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.rabbitmq.threadPoolSize": {
"name": "camel.component.rabbitmq.threadPoolSize",
"description": "The consumer uses a Thread Pool
Executor with a fixed number of threads. This setting allows you to set that
number of threads.",
diff --git
a/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-source.json
b/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-source.json
index fa59ee0..3fe51b0 100644
---
a/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-source.json
+++
b/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-source.json
@@ -232,6 +232,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.recoverFromDeclareException": {
+ "name":
"camel.source.endpoint.recoverFromDeclareException",
+ "description": "Decides whether an exception during
declaration of exchanges or queues is recoverable or not. If the option is
false, camel will throw an exception when starting the consumer, which will
interrupt application startup (e.g. in the case when the exchange \/ queue is
already declared in RabbitMQ and has incompatible configuration). If set to
true, the consumer will try to reconnect periodically.",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.reQueue": {
"name": "camel.source.endpoint.reQueue",
"description": "This is used by the consumer to control
rejection of the message. When the consumer is complete processing the
exchange, and if the exchange failed, then the consumer is going to reject the
message from the RabbitMQ broker. If the header CamelRabbitmqRequeue is present
then the value of the header will be used, otherwise this endpoint value is
used as fallback. If the value is false (by default) then the message is
discarded\/dead-lettered. If the value is true, then t [...]
@@ -542,6 +549,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.rabbitmq.recoverFromDeclareException": {
+ "name":
"camel.component.rabbitmq.recoverFromDeclareException",
+ "description": "Decides whether an exception during
declaration of exchanges or queues is recoverable or not. If the option is
false, camel will throw an exception when starting the consumer, which will
interrupt application startup (e.g. in the case when the exchange \/ queue is
already declared in RabbitMQ and has incompatible configuration). If set to
true, the consumer will try to reconnect periodically.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.rabbitmq.threadPoolSize": {
"name": "camel.component.rabbitmq.threadPoolSize",
"description": "The consumer uses a Thread Pool
Executor with a fixed number of threads. This setting allows you to set that
number of threads.",
diff --git
a/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-source-connector.adoc
b/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-source-connector.adoc
index 7607b91..0285a7d 100644
---
a/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-source-connector.adoc
+++
b/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSourceConn
----
-The camel-rabbitmq source connector supports 97 options, which are listed
below.
+The camel-rabbitmq source connector supports 99 options, which are listed
below.
@@ -63,6 +63,7 @@ The camel-rabbitmq source connector supports 97 options,
which are listed below.
| *camel.source.endpoint.prefetchEnabled* | Enables the quality of service on
the RabbitMQConsumer side. You need to specify the option of prefetchSize,
prefetchCount, prefetchGlobal at the same time | false | false | MEDIUM
| *camel.source.endpoint.prefetchGlobal* | If the settings should be applied
to the entire channel rather than each consumer You need to specify the option
of prefetchSize, prefetchCount, prefetchGlobal at the same time | false | false
| MEDIUM
| *camel.source.endpoint.prefetchSize* | The maximum amount of content
(measured in octets) that the server will deliver, 0 if unlimited. You need to
specify the option of prefetchSize, prefetchCount, prefetchGlobal at the same
time | null | false | MEDIUM
+| *camel.source.endpoint.recoverFromDeclareException* | Decides whether an
exception during declaration of exchanges or queues is recoverable or not. If
the option is false, camel will throw an exception when starting the consumer,
which will interrupt application startup (e.g. in the case when the exchange /
queue is already declared in RabbitMQ and has incompatible configuration). If
set to true, the consumer will try to reconnect periodically. | true | false |
MEDIUM
| *camel.source.endpoint.reQueue* | This is used by the consumer to control
rejection of the message. When the consumer is complete processing the
exchange, and if the exchange failed, then the consumer is going to reject the
message from the RabbitMQ broker. If the header CamelRabbitmqRequeue is present
then the value of the header will be used, otherwise this endpoint value is
used as fallback. If the value is false (by default) then the message is
discarded/dead-lettered. If the value [...]
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
@@ -108,6 +109,7 @@ The camel-rabbitmq source connector supports 97 options,
which are listed below.
| *camel.component.rabbitmq.prefetchEnabled* | Enables the quality of service
on the RabbitMQConsumer side. You need to specify the option of prefetchSize,
prefetchCount, prefetchGlobal at the same time | false | false | MEDIUM
| *camel.component.rabbitmq.prefetchGlobal* | If the settings should be
applied to the entire channel rather than each consumer You need to specify the
option of prefetchSize, prefetchCount, prefetchGlobal at the same time | false
| false | MEDIUM
| *camel.component.rabbitmq.prefetchSize* | The maximum amount of content
(measured in octets) that the server will deliver, 0 if unlimited. You need to
specify the option of prefetchSize, prefetchCount, prefetchGlobal at the same
time | null | false | MEDIUM
+| *camel.component.rabbitmq.recoverFromDeclare Exception* | Decides whether an
exception during declaration of exchanges or queues is recoverable or not. If
the option is false, camel will throw an exception when starting the consumer,
which will interrupt application startup (e.g. in the case when the exchange /
queue is already declared in RabbitMQ and has incompatible configuration). If
set to true, the consumer will try to reconnect periodically. | false | false |
MEDIUM
| *camel.component.rabbitmq.threadPoolSize* | The consumer uses a Thread Pool
Executor with a fixed number of threads. This setting allows you to set that
number of threads. | 10 | false | MEDIUM
| *camel.component.rabbitmq.args* | Specify arguments for configuring the
different RabbitMQ concepts, a different prefix is required for each: Exchange:
arg.exchange. Queue: arg.queue. Binding: arg.binding. DLQ: arg.dlq.queue. DLQ
Binding: arg.dlq.binding. For example to declare a queue with message ttl
argument:
\http://localhost:5672/exchange/queueargs=arg.queue.x-message-ttl=60000 | null
| false | MEDIUM
| *camel.component.rabbitmq.autoDetectConnection Factory* | Whether to
auto-detect looking up RabbitMQ connection factory from the registry. When
enabled and a single instance of the connection factory is found then it will
be used. An explicit connection factory can be configured on the component or
endpoint level which takes precedence. | true | false | MEDIUM
diff --git
a/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSourceConnectorConfig.java
b/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSourceConnectorConfig.java
index bb1951e..b39818b 100644
---
a/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSourceConnectorConfig.java
+++
b/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSourceConnectorConfig.java
@@ -122,6 +122,9 @@ public class CamelRabbitmqSourceConnectorConfig
public static final String
CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_SIZE_CONF =
"camel.source.endpoint.prefetchSize";
public static final String
CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_SIZE_DOC = "The maximum amount of
content (measured in octets) that the server will deliver, 0 if unlimited. You
need to specify the option of prefetchSize, prefetchCount, prefetchGlobal at
the same time";
public static final Integer
CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_SIZE_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_RABBITMQ_ENDPOINT_RECOVER_FROM_DECLARE_EXCEPTION_CONF =
"camel.source.endpoint.recoverFromDeclareException";
+ public static final String
CAMEL_SOURCE_RABBITMQ_ENDPOINT_RECOVER_FROM_DECLARE_EXCEPTION_DOC = "Decides
whether an exception during declaration of exchanges or queues is recoverable
or not. If the option is false, camel will throw an exception when starting the
consumer, which will interrupt application startup (e.g. in the case when the
exchange / queue is already declared in RabbitMQ and has incompatible
configuration). If set to true, the consumer will try to reconnect
periodically.";
+ public static final Boolean
CAMEL_SOURCE_RABBITMQ_ENDPOINT_RECOVER_FROM_DECLARE_EXCEPTION_DEFAULT = true;
public static final String CAMEL_SOURCE_RABBITMQ_ENDPOINT_RE_QUEUE_CONF =
"camel.source.endpoint.reQueue";
public static final String CAMEL_SOURCE_RABBITMQ_ENDPOINT_RE_QUEUE_DOC =
"This is used by the consumer to control rejection of the message. When the
consumer is complete processing the exchange, and if the exchange failed, then
the consumer is going to reject the message from the RabbitMQ broker. If the
header CamelRabbitmqRequeue is present then the value of the header will be
used, otherwise this endpoint value is used as fallback. If the value is false
(by default) then the messag [...]
public static final Boolean
CAMEL_SOURCE_RABBITMQ_ENDPOINT_RE_QUEUE_DEFAULT = false;
@@ -257,6 +260,9 @@ public class CamelRabbitmqSourceConnectorConfig
public static final String
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_SIZE_CONF =
"camel.component.rabbitmq.prefetchSize";
public static final String
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_SIZE_DOC = "The maximum amount of
content (measured in octets) that the server will deliver, 0 if unlimited. You
need to specify the option of prefetchSize, prefetchCount, prefetchGlobal at
the same time";
public static final Integer
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_SIZE_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_RABBITMQ_COMPONENT_RECOVER_FROM_DECLARE_EXCEPTION_CONF =
"camel.component.rabbitmq.recoverFromDeclareException";
+ public static final String
CAMEL_SOURCE_RABBITMQ_COMPONENT_RECOVER_FROM_DECLARE_EXCEPTION_DOC = "Decides
whether an exception during declaration of exchanges or queues is recoverable
or not. If the option is false, camel will throw an exception when starting the
consumer, which will interrupt application startup (e.g. in the case when the
exchange / queue is already declared in RabbitMQ and has incompatible
configuration). If set to true, the consumer will try to reconnect
periodically.";
+ public static final Boolean
CAMEL_SOURCE_RABBITMQ_COMPONENT_RECOVER_FROM_DECLARE_EXCEPTION_DEFAULT = false;
public static final String
CAMEL_SOURCE_RABBITMQ_COMPONENT_THREAD_POOL_SIZE_CONF =
"camel.component.rabbitmq.threadPoolSize";
public static final String
CAMEL_SOURCE_RABBITMQ_COMPONENT_THREAD_POOL_SIZE_DOC = "The consumer uses a
Thread Pool Executor with a fixed number of threads. This setting allows you to
set that number of threads.";
public static final Integer
CAMEL_SOURCE_RABBITMQ_COMPONENT_THREAD_POOL_SIZE_DEFAULT = 10;
@@ -362,6 +368,7 @@ public class CamelRabbitmqSourceConnectorConfig
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_ENABLED_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_GLOBAL_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_GLOBAL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_GLOBAL_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_RABBITMQ_ENDPOINT_PREFETCH_SIZE_DOC);
+
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_RECOVER_FROM_DECLARE_EXCEPTION_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_RECOVER_FROM_DECLARE_EXCEPTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_RECOVER_FROM_DECLARE_EXCEPTION_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_RE_QUEUE_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_RABBITMQ_ENDPOINT_RE_QUEUE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_RABBITMQ_ENDPOINT_RE_QUEUE_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_ENDPOINT_EXCHANGE_PATTERN_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_RABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DOC);
@@ -407,6 +414,7 @@ public class CamelRabbitmqSourceConnectorConfig
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_ENABLED_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_GLOBAL_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_GLOBAL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_GLOBAL_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_RABBITMQ_COMPONENT_PREFETCH_SIZE_DOC);
+
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_RECOVER_FROM_DECLARE_EXCEPTION_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_RABBITMQ_COMPONENT_RECOVER_FROM_DECLARE_EXCEPTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_COMPONENT_RECOVER_FROM_DECLARE_EXCEPTION_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_THREAD_POOL_SIZE_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_RABBITMQ_COMPONENT_THREAD_POOL_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_COMPONENT_THREAD_POOL_SIZE_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_ARGS_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_RABBITMQ_COMPONENT_ARGS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_RABBITMQ_COMPONENT_ARGS_DOC);
conf.define(CAMEL_SOURCE_RABBITMQ_COMPONENT_AUTO_DETECT_CONNECTION_FACTORY_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_RABBITMQ_COMPONENT_AUTO_DETECT_CONNECTION_FACTORY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_RABBITMQ_COMPONENT_AUTO_DETECT_CONNECTION_FACTORY_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-source-connector.adoc
index ae21650..0285a7d 100644
---
a/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSourceConn
----
-The camel-rabbitmq source connector supports 97 options, which are listed
below.
+The camel-rabbitmq source connector supports 99 options, which are listed
below.
@@ -63,6 +63,7 @@ The camel-rabbitmq source connector supports 97 options,
which are listed below.
| *camel.source.endpoint.prefetchEnabled* | Enables the quality of service on
the RabbitMQConsumer side. You need to specify the option of prefetchSize,
prefetchCount, prefetchGlobal at the same time | false | false | MEDIUM
| *camel.source.endpoint.prefetchGlobal* | If the settings should be applied
to the entire channel rather than each consumer You need to specify the option
of prefetchSize, prefetchCount, prefetchGlobal at the same time | false | false
| MEDIUM
| *camel.source.endpoint.prefetchSize* | The maximum amount of content
(measured in octets) that the server will deliver, 0 if unlimited. You need to
specify the option of prefetchSize, prefetchCount, prefetchGlobal at the same
time | null | false | MEDIUM
+| *camel.source.endpoint.recoverFromDeclareException* | Decides whether an
exception during declaration of exchanges or queues is recoverable or not. If
the option is false, camel will throw an exception when starting the consumer,
which will interrupt application startup (e.g. in the case when the exchange /
queue is already declared in RabbitMQ and has incompatible configuration). If
set to true, the consumer will try to reconnect periodically. | true | false |
MEDIUM
| *camel.source.endpoint.reQueue* | This is used by the consumer to control
rejection of the message. When the consumer is complete processing the
exchange, and if the exchange failed, then the consumer is going to reject the
message from the RabbitMQ broker. If the header CamelRabbitmqRequeue is present
then the value of the header will be used, otherwise this endpoint value is
used as fallback. If the value is false (by default) then the message is
discarded/dead-lettered. If the value [...]
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
@@ -108,6 +109,7 @@ The camel-rabbitmq source connector supports 97 options,
which are listed below.
| *camel.component.rabbitmq.prefetchEnabled* | Enables the quality of service
on the RabbitMQConsumer side. You need to specify the option of prefetchSize,
prefetchCount, prefetchGlobal at the same time | false | false | MEDIUM
| *camel.component.rabbitmq.prefetchGlobal* | If the settings should be
applied to the entire channel rather than each consumer You need to specify the
option of prefetchSize, prefetchCount, prefetchGlobal at the same time | false
| false | MEDIUM
| *camel.component.rabbitmq.prefetchSize* | The maximum amount of content
(measured in octets) that the server will deliver, 0 if unlimited. You need to
specify the option of prefetchSize, prefetchCount, prefetchGlobal at the same
time | null | false | MEDIUM
+| *camel.component.rabbitmq.recoverFromDeclare Exception* | Decides whether an
exception during declaration of exchanges or queues is recoverable or not. If
the option is false, camel will throw an exception when starting the consumer,
which will interrupt application startup (e.g. in the case when the exchange /
queue is already declared in RabbitMQ and has incompatible configuration). If
set to true, the consumer will try to reconnect periodically. | false | false |
MEDIUM
| *camel.component.rabbitmq.threadPoolSize* | The consumer uses a Thread Pool
Executor with a fixed number of threads. This setting allows you to set that
number of threads. | 10 | false | MEDIUM
| *camel.component.rabbitmq.args* | Specify arguments for configuring the
different RabbitMQ concepts, a different prefix is required for each: Exchange:
arg.exchange. Queue: arg.queue. Binding: arg.binding. DLQ: arg.dlq.queue. DLQ
Binding: arg.dlq.binding. For example to declare a queue with message ttl
argument:
\http://localhost:5672/exchange/queueargs=arg.queue.x-message-ttl=60000 | null
| false | MEDIUM
| *camel.component.rabbitmq.autoDetectConnection Factory* | Whether to
auto-detect looking up RabbitMQ connection factory from the registry. When
enabled and a single instance of the connection factory is found then it will
be used. An explicit connection factory can be configured on the component or
endpoint level which takes precedence. | true | false | MEDIUM
@@ -145,8 +147,4 @@ The camel-rabbitmq source connector has no transforms out
of the box.
The camel-rabbitmq source connector has no aggregation strategies out of the
box.
-
-
-
-
// kafka-connector options: END
