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 276790e [create-pull-request] automated change
276790e is described below
commit 276790e192a877797f2c62d1fd1c1583bdf9c432
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon May 3 04:36:54 2021 +0000
[create-pull-request] automated change
---
.../src/generated/resources/connectors/camel-activemq-source.json | 6 ++++++
.../src/generated/resources/camel-activemq-source.json | 6 ++++++
.../src/main/docs/camel-activemq-kafka-source-connector.adoc | 3 ++-
.../kafkaconnector/activemq/CamelActivemqSourceConnectorConfig.java | 4 ++++
.../pages/connectors/camel-activemq-kafka-source-connector.adoc | 3 ++-
5 files changed, 20 insertions(+), 2 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
index cbb1489..9e27c57 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-activemq-source.json
@@ -214,6 +214,12 @@
"SimpleAsync"
]
},
+ "camel.source.endpoint.destinationOptions": {
+ "name": "camel.source.endpoint.destinationOptions",
+ "description": "Destination Options are a way to
provide extended configuration options to a JMS consumer without having to
extend the JMS API. The options are encoded using URL query syntax in the
destination name that the consumer is created on. See more details at
https:\/\/activemq.apache.org\/destination-options.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.eagerLoadingOfProperties": {
"name":
"camel.source.endpoint.eagerLoadingOfProperties",
"description": "Enables eager loading of JMS properties
and payload as soon as a message is loaded which generally is inefficient as
the JMS properties may not be required but sometimes can catch early any issues
with the underlying JMS provider and the use of JMS properties. See also the
option eagerPoisonBody.",
diff --git
a/connectors/camel-activemq-kafka-connector/src/generated/resources/camel-activemq-source.json
b/connectors/camel-activemq-kafka-connector/src/generated/resources/camel-activemq-source.json
index cbb1489..9e27c57 100644
---
a/connectors/camel-activemq-kafka-connector/src/generated/resources/camel-activemq-source.json
+++
b/connectors/camel-activemq-kafka-connector/src/generated/resources/camel-activemq-source.json
@@ -214,6 +214,12 @@
"SimpleAsync"
]
},
+ "camel.source.endpoint.destinationOptions": {
+ "name": "camel.source.endpoint.destinationOptions",
+ "description": "Destination Options are a way to
provide extended configuration options to a JMS consumer without having to
extend the JMS API. The options are encoded using URL query syntax in the
destination name that the consumer is created on. See more details at
https:\/\/activemq.apache.org\/destination-options.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.eagerLoadingOfProperties": {
"name":
"camel.source.endpoint.eagerLoadingOfProperties",
"description": "Enables eager loading of JMS properties
and payload as soon as a message is loaded which generally is inefficient as
the JMS properties may not be required but sometimes can catch early any issues
with the underlying JMS provider and the use of JMS properties. See also the
option eagerPoisonBody.",
diff --git
a/connectors/camel-activemq-kafka-connector/src/main/docs/camel-activemq-kafka-source-connector.adoc
b/connectors/camel-activemq-kafka-connector/src/main/docs/camel-activemq-kafka-source-connector.adoc
index 1b563de..1a01891 100644
---
a/connectors/camel-activemq-kafka-connector/src/main/docs/camel-activemq-kafka-source-connector.adoc
+++
b/connectors/camel-activemq-kafka-connector/src/main/docs/camel-activemq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConn
----
-The camel-activemq source connector supports 149 options, which are listed
below.
+The camel-activemq source connector supports 150 options, which are listed
below.
@@ -57,6 +57,7 @@ The camel-activemq source connector supports 149 options,
which are listed below
| *camel.source.endpoint.allowReplyManagerQuickStop* | Whether the
DefaultMessageListenerContainer used in the reply managers for request-reply
messaging allow the DefaultMessageListenerContainer.runningAllowed flag to
quick stop in case JmsConfiguration#isAcceptMessagesWhileStopping is enabled,
and org.apache.camel.CamelContext is currently being stopped. This quick stop
ability is enabled by default in the regular JMS consumers but to enable for
reply managers you must enable this flag [...]
| *camel.source.endpoint.consumerType* | The consumer type to use, which can
be one of: Simple, Default, or Custom. The consumer type determines which
Spring JMS listener to use. Default will use
org.springframework.jms.listener.DefaultMessageListenerContainer, Simple will
use org.springframework.jms.listener.SimpleMessageListenerContainer. When
Custom is specified, the MessageListenerContainerFactory defined by the
messageListenerContainerFactory option will determine what org.springfra [...]
| *camel.source.endpoint.defaultTaskExecutorType* | Specifies what default
TaskExecutor type to use in the DefaultMessageListenerContainer, for both
consumer endpoints and the ReplyTo consumer of producer endpoints. Possible
values: SimpleAsync (uses Spring's SimpleAsyncTaskExecutor) or ThreadPool (uses
Spring's ThreadPoolTaskExecutor with optimal values - cached threadpool-like).
If not set, it defaults to the previous behaviour, which uses a cached thread
pool for consumer endpoints an [...]
+| *camel.source.endpoint.destinationOptions* | Destination Options are a way
to provide extended configuration options to a JMS consumer without having to
extend the JMS API. The options are encoded using URL query syntax in the
destination name that the consumer is created on. See more details at
\https://activemq.apache.org/destination-options. | null | false | MEDIUM
| *camel.source.endpoint.eagerLoadingOfProperties* | Enables eager loading of
JMS properties and payload as soon as a message is loaded which generally is
inefficient as the JMS properties may not be required but sometimes can catch
early any issues with the underlying JMS provider and the use of JMS
properties. See also the option eagerPoisonBody. | false | false | MEDIUM
| *camel.source.endpoint.eagerPoisonBody* | If eagerLoadingOfProperties is
enabled and the JMS message payload (JMS body or JMS properties) is poison
(cannot be read/mapped), then set this text as the message body instead so the
message can be processed (the cause of the poison are already stored as
exception on the Exchange). This can be turned off by setting
eagerPoisonBody=false. See also the option eagerLoadingOfProperties. | "Poison
JMS message due to ${exception.message}" | false | MEDIUM
| *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
diff --git
a/connectors/camel-activemq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/activemq/CamelActivemqSourceConnectorConfig.java
b/connectors/camel-activemq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/activemq/CamelActivemqSourceConnectorConfig.java
index 15fe3c8..38635a1 100644
---
a/connectors/camel-activemq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/activemq/CamelActivemqSourceConnectorConfig.java
+++
b/connectors/camel-activemq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/activemq/CamelActivemqSourceConnectorConfig.java
@@ -104,6 +104,9 @@ public class CamelActivemqSourceConnectorConfig
public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DEFAULT_TASK_EXECUTOR_TYPE_CONF =
"camel.source.endpoint.defaultTaskExecutorType";
public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DEFAULT_TASK_EXECUTOR_TYPE_DOC = "Specifies what
default TaskExecutor type to use in the DefaultMessageListenerContainer, for
both consumer endpoints and the ReplyTo consumer of producer endpoints.
Possible values: SimpleAsync (uses Spring's SimpleAsyncTaskExecutor) or
ThreadPool (uses Spring's ThreadPoolTaskExecutor with optimal values - cached
threadpool-like). If not set, it defaults to the previous behaviour, which uses
a [...]
public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DEFAULT_TASK_EXECUTOR_TYPE_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DESTINATION_OPTIONS_CONF =
"camel.source.endpoint.destinationOptions";
+ public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DESTINATION_OPTIONS_DOC = "Destination Options
are a way to provide extended configuration options to a JMS consumer without
having to extend the JMS API. The options are encoded using URL query syntax in
the destination name that the consumer is created on. See more details at
https://activemq.apache.org/destination-options.";;
+ public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DESTINATION_OPTIONS_DEFAULT = null;
public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_LOADING_OF_PROPERTIES_CONF =
"camel.source.endpoint.eagerLoadingOfProperties";
public static final String
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_LOADING_OF_PROPERTIES_DOC = "Enables eager
loading of JMS properties and payload as soon as a message is loaded which
generally is inefficient as the JMS properties may not be required but
sometimes can catch early any issues with the underlying JMS provider and the
use of JMS properties. See also the option eagerPoisonBody.";
public static final Boolean
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_LOADING_OF_PROPERTIES_DEFAULT = false;
@@ -512,6 +515,7 @@ public class CamelActivemqSourceConnectorConfig
conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_ALLOW_REPLY_MANAGER_QUICK_STOP_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_ALLOW_REPLY_MANAGER_QUICK_STOP_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_ALLOW_REPLY_MANAGER_QUICK_STOP_DOC);
conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_CONSUMER_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_CONSUMER_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_CONSUMER_TYPE_DOC);
conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DEFAULT_TASK_EXECUTOR_TYPE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DEFAULT_TASK_EXECUTOR_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DEFAULT_TASK_EXECUTOR_TYPE_DOC);
+ conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DESTINATION_OPTIONS_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DESTINATION_OPTIONS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_DESTINATION_OPTIONS_DOC);
conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_LOADING_OF_PROPERTIES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_LOADING_OF_PROPERTIES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_LOADING_OF_PROPERTIES_DOC);
conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_POISON_BODY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_POISON_BODY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EAGER_POISON_BODY_DOC);
conf.define(CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ACTIVEMQ_ENDPOINT_EXCEPTION_HANDLER_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-activemq-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-activemq-kafka-source-connector.adoc
index 1b563de..1a01891 100644
---
a/docs/modules/ROOT/pages/connectors/camel-activemq-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-activemq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.activemq.CamelActivemqSourceConn
----
-The camel-activemq source connector supports 149 options, which are listed
below.
+The camel-activemq source connector supports 150 options, which are listed
below.
@@ -57,6 +57,7 @@ The camel-activemq source connector supports 149 options,
which are listed below
| *camel.source.endpoint.allowReplyManagerQuickStop* | Whether the
DefaultMessageListenerContainer used in the reply managers for request-reply
messaging allow the DefaultMessageListenerContainer.runningAllowed flag to
quick stop in case JmsConfiguration#isAcceptMessagesWhileStopping is enabled,
and org.apache.camel.CamelContext is currently being stopped. This quick stop
ability is enabled by default in the regular JMS consumers but to enable for
reply managers you must enable this flag [...]
| *camel.source.endpoint.consumerType* | The consumer type to use, which can
be one of: Simple, Default, or Custom. The consumer type determines which
Spring JMS listener to use. Default will use
org.springframework.jms.listener.DefaultMessageListenerContainer, Simple will
use org.springframework.jms.listener.SimpleMessageListenerContainer. When
Custom is specified, the MessageListenerContainerFactory defined by the
messageListenerContainerFactory option will determine what org.springfra [...]
| *camel.source.endpoint.defaultTaskExecutorType* | Specifies what default
TaskExecutor type to use in the DefaultMessageListenerContainer, for both
consumer endpoints and the ReplyTo consumer of producer endpoints. Possible
values: SimpleAsync (uses Spring's SimpleAsyncTaskExecutor) or ThreadPool (uses
Spring's ThreadPoolTaskExecutor with optimal values - cached threadpool-like).
If not set, it defaults to the previous behaviour, which uses a cached thread
pool for consumer endpoints an [...]
+| *camel.source.endpoint.destinationOptions* | Destination Options are a way
to provide extended configuration options to a JMS consumer without having to
extend the JMS API. The options are encoded using URL query syntax in the
destination name that the consumer is created on. See more details at
\https://activemq.apache.org/destination-options. | null | false | MEDIUM
| *camel.source.endpoint.eagerLoadingOfProperties* | Enables eager loading of
JMS properties and payload as soon as a message is loaded which generally is
inefficient as the JMS properties may not be required but sometimes can catch
early any issues with the underlying JMS provider and the use of JMS
properties. See also the option eagerPoisonBody. | false | false | MEDIUM
| *camel.source.endpoint.eagerPoisonBody* | If eagerLoadingOfProperties is
enabled and the JMS message payload (JMS body or JMS properties) is poison
(cannot be read/mapped), then set this text as the message body instead so the
message can be processed (the cause of the poison are already stored as
exception on the Exchange). This can be turned off by setting
eagerPoisonBody=false. See also the option eagerLoadingOfProperties. | "Poison
JMS message due to ${exception.message}" | false | MEDIUM
| *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
