This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/master by this push:
new 2a4996c Regen
2a4996c is described below
commit 2a4996ca84958bddcdc4f88204ab5128461402ef
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Jan 21 10:16:16 2021 +0100
Regen
---
.../springboot/catalog/components/activemq.json | 2 ++
.../camel/springboot/catalog/components/amqp.json | 2 ++
.../camel/springboot/catalog/components/jms.json | 2 ++
.../src/main/docs/activemq-starter.adoc | 3 ++-
.../springboot/ActiveMQComponentConfiguration.java | 21 +++++++++++++++++++++
.../src/main/docs/amqp-starter.adoc | 3 ++-
.../amqp/springboot/AMQPComponentConfiguration.java | 21 +++++++++++++++++++++
.../src/main/docs/jms-starter.adoc | 3 ++-
.../jms/springboot/JmsComponentConfiguration.java | 21 +++++++++++++++++++++
docs/modules/ROOT/pages/activemq-starter.adoc | 3 ++-
docs/modules/ROOT/pages/amqp-starter.adoc | 3 ++-
docs/modules/ROOT/pages/jms-starter.adoc | 3 ++-
12 files changed, 81 insertions(+), 6 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
index d9b3819..bd69cc0 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
@@ -33,6 +33,7 @@
"usePooledConnection": { "kind": "property", "displayName": "Use Pooled
Connection", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": true, "description":
"Enables or disables whether a PooledConnectionFactory will be used so that
when messages are sent to ActiveMQ from outside of a message consuming thread,
pooling will be used rather tha [...]
"useSingleConnection": { "kind": "property", "displayName": "Use Single
Connection", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": false, "description":
"Enables or disables whether a Spring SingleConnectionFactory will be used so
that when messages are sent to ActiveMQ from outside of a message consuming
thread, pooling will be used ra [...]
"acknowledgementModeName": { "kind": "property", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFiel [...]
+ "artemisConsumerPriority": { "kind": "property", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. N [...]
"asyncConsumer": { "kind": "property", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may picku [...]
"autoStartup": { "kind": "property", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "property", "displayName": "Cache Level", "group":
"consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the cache level by
ID for the underlying JMS resources. See cacheLevelName option for more
details." },
@@ -135,6 +136,7 @@
"replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in
consumer)." },
"testConnectionOnStartup": { "kind": "parameter", "displayName": "Test
Connection On Startup", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to test the connection on
startup. This ensures that when Camel starts th [...]
"acknowledgementModeName": { "kind": "parameter", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFie [...]
+ "artemisConsumerPriority": { "kind": "parameter", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. [...]
"asyncConsumer": { "kind": "parameter", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may pick [...]
"autoStartup": { "kind": "parameter", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "parameter", "displayName": "Cache Level",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the cache level by
ID for the underlying JMS resources. See cacheLevelName option for more
details." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/amqp.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/amqp.json
index ae7f332..c3495a7 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/amqp.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/amqp.json
@@ -31,6 +31,7 @@
"replyTo": { "kind": "property", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in
consumer)." },
"testConnectionOnStartup": { "kind": "property", "displayName": "Test
Connection On Startup", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to test the connection on
startup. This ensures that when Camel starts tha [...]
"acknowledgementModeName": { "kind": "property", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFiel [...]
+ "artemisConsumerPriority": { "kind": "property", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. N [...]
"asyncConsumer": { "kind": "property", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may picku [...]
"autoStartup": { "kind": "property", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "property", "displayName": "Cache Level", "group":
"consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the cache level by
ID for the underlying JMS resources. See cacheLevelName option for more
details." },
@@ -132,6 +133,7 @@
"replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in
consumer)." },
"testConnectionOnStartup": { "kind": "parameter", "displayName": "Test
Connection On Startup", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to test the connection on
startup. This ensures that when Camel starts th [...]
"acknowledgementModeName": { "kind": "parameter", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFie [...]
+ "artemisConsumerPriority": { "kind": "parameter", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. [...]
"asyncConsumer": { "kind": "parameter", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may pick [...]
"autoStartup": { "kind": "parameter", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "parameter", "displayName": "Cache Level",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the cache level by
ID for the underlying JMS resources. See cacheLevelName option for more
details." },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/jms.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/jms.json
index cfbf0bf..0a01106 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/jms.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/jms.json
@@ -31,6 +31,7 @@
"replyTo": { "kind": "property", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in
consumer)." },
"testConnectionOnStartup": { "kind": "property", "displayName": "Test
Connection On Startup", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to test the connection on
startup. This ensures that when Camel starts tha [...]
"acknowledgementModeName": { "kind": "property", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFiel [...]
+ "artemisConsumerPriority": { "kind": "property", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. N [...]
"asyncConsumer": { "kind": "property", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may picku [...]
"autoStartup": { "kind": "property", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "property", "displayName": "Cache Level", "group":
"consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the cache level by
ID for the underlying JMS resources. See cacheLevelName option for more
details." },
@@ -132,6 +133,7 @@
"replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in
consumer)." },
"testConnectionOnStartup": { "kind": "parameter", "displayName": "Test
Connection On Startup", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to test the connection on
startup. This ensures that when Camel starts th [...]
"acknowledgementModeName": { "kind": "parameter", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFie [...]
+ "artemisConsumerPriority": { "kind": "parameter", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. [...]
"asyncConsumer": { "kind": "parameter", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may pick [...]
"autoStartup": { "kind": "parameter", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "parameter", "displayName": "Cache Level",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the cache level by
ID for the underlying JMS resources. See cacheLevelName option for more
details." },
diff --git
a/components-starter/camel-activemq-starter/src/main/docs/activemq-starter.adoc
b/components-starter/camel-activemq-starter/src/main/docs/activemq-starter.adoc
index ebea80f..abde141 100644
---
a/components-starter/camel-activemq-starter/src/main/docs/activemq-starter.adoc
+++
b/components-starter/camel-activemq-starter/src/main/docs/activemq-starter.adoc
@@ -17,7 +17,7 @@ When using activemq with Spring Boot make sure to use the
following Maven depend
----
-The component supports 102 options, which are listed below.
+The component supports 103 options, which are listed below.
@@ -33,6 +33,7 @@ The component supports 102 options, which are listed below.
| *camel.component.activemq.allow-reply-manager-quick-stop* | 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 th [...]
| *camel.component.activemq.allow-serialized-headers* | Controls whether or
not to include serialized headers. Applies only when transferExchange is true.
This requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level. | false | Boolean
| *camel.component.activemq.always-copy-message* | If true, Camel will always
make a JMS message copy of the message when it is passed to the producer for
sending. Copying the message is needed in some situations, such as when a
replyToDestinationSelectorName is set (incidentally, Camel will set the
alwaysCopyMessage option to true, if a replyToDestinationSelectorName is set) |
false | Boolean
+| *camel.component.activemq.artemis-consumer-priority* | Consumer priorities
allow you to ensure that high priority consumers receive messages while they
are active. Normally, active consumers connected to a queue receive messages
from it in a round-robin fashion. When consumer priorities are in use, messages
are delivered round-robin if multiple active consumers exist with the same high
priority. Messages will only going to lower priority consumers when the high
priority consumers do no [...]
| *camel.component.activemq.artemis-streaming-enabled* | Whether optimizing
for Apache Artemis streaming mode. | true | Boolean
| *camel.component.activemq.async-consumer* | Whether the JmsConsumer
processes the Exchange asynchronously. If enabled then the JmsConsumer may
pickup the next message from the JMS queue, while the previous message is being
processed asynchronously (by the Asynchronous Routing Engine). This means that
messages may be processed not 100% strictly in order. If disabled (as default)
then the Exchange is fully processed before the JmsConsumer will pickup the
next message from the JMS queue. [...]
| *camel.component.activemq.async-start-listener* | Whether to startup the
JmsConsumer message listener asynchronously, when starting a route. For example
if a JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover. This will cause Camel to block while
starting routes. By setting this option to true, you will let routes startup,
while the JmsConsumer connects to the JMS broker using a dedicated thread in
asynchronous mode. If this opt [...]
diff --git
a/components-starter/camel-activemq-starter/src/main/java/org/apache/camel/component/activemq/springboot/ActiveMQComponentConfiguration.java
b/components-starter/camel-activemq-starter/src/main/java/org/apache/camel/component/activemq/springboot/ActiveMQComponentConfiguration.java
index 5b8dd02..b447022 100644
---
a/components-starter/camel-activemq-starter/src/main/java/org/apache/camel/component/activemq/springboot/ActiveMQComponentConfiguration.java
+++
b/components-starter/camel-activemq-starter/src/main/java/org/apache/camel/component/activemq/springboot/ActiveMQComponentConfiguration.java
@@ -135,6 +135,19 @@ public class ActiveMQComponentConfiguration
*/
private String acknowledgementModeName = "AUTO_ACKNOWLEDGE";
/**
+ * Consumer priorities allow you to ensure that high priority consumers
+ * receive messages while they are active. Normally, active consumers
+ * connected to a queue receive messages from it in a round-robin fashion.
+ * When consumer priorities are in use, messages are delivered round-robin
+ * if multiple active consumers exist with the same high priority. Messages
+ * will only going to lower priority consumers when the high priority
+ * consumers do not have credit available to consume the message, or those
+ * high priority consumers have declined to accept the message (for
instance
+ * because it does not meet the criteria of any selectors associated with
+ * the consumer).
+ */
+ private Integer artemisConsumerPriority;
+ /**
* Whether the JmsConsumer processes the Exchange asynchronously. If
enabled
* then the JmsConsumer may pickup the next message from the JMS queue,
* while the previous message is being processed asynchronously (by the
@@ -889,6 +902,14 @@ public class ActiveMQComponentConfiguration
this.acknowledgementModeName = acknowledgementModeName;
}
+ public Integer getArtemisConsumerPriority() {
+ return artemisConsumerPriority;
+ }
+
+ public void setArtemisConsumerPriority(Integer artemisConsumerPriority) {
+ this.artemisConsumerPriority = artemisConsumerPriority;
+ }
+
public Boolean getAsyncConsumer() {
return asyncConsumer;
}
diff --git
a/components-starter/camel-amqp-starter/src/main/docs/amqp-starter.adoc
b/components-starter/camel-amqp-starter/src/main/docs/amqp-starter.adoc
index f1edf8f..8dc5866 100644
--- a/components-starter/camel-amqp-starter/src/main/docs/amqp-starter.adoc
+++ b/components-starter/camel-amqp-starter/src/main/docs/amqp-starter.adoc
@@ -17,7 +17,7 @@ When using amqp with Spring Boot make sure to use the
following Maven dependency
----
-The component supports 99 options, which are listed below.
+The component supports 100 options, which are listed below.
@@ -33,6 +33,7 @@ The component supports 99 options, which are listed below.
| *camel.component.amqp.allow-reply-manager-quick-stop* | 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 f [...]
| *camel.component.amqp.allow-serialized-headers* | Controls whether or not to
include serialized headers. Applies only when transferExchange is true. This
requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level. | false | Boolean
| *camel.component.amqp.always-copy-message* | If true, Camel will always make
a JMS message copy of the message when it is passed to the producer for
sending. Copying the message is needed in some situations, such as when a
replyToDestinationSelectorName is set (incidentally, Camel will set the
alwaysCopyMessage option to true, if a replyToDestinationSelectorName is set) |
false | Boolean
+| *camel.component.amqp.artemis-consumer-priority* | Consumer priorities allow
you to ensure that high priority consumers receive messages while they are
active. Normally, active consumers connected to a queue receive messages from
it in a round-robin fashion. When consumer priorities are in use, messages are
delivered round-robin if multiple active consumers exist with the same high
priority. Messages will only going to lower priority consumers when the high
priority consumers do not ha [...]
| *camel.component.amqp.artemis-streaming-enabled* | Whether optimizing for
Apache Artemis streaming mode. | true | Boolean
| *camel.component.amqp.async-consumer* | Whether the JmsConsumer processes
the Exchange asynchronously. If enabled then the JmsConsumer may pickup the
next message from the JMS queue, while the previous message is being processed
asynchronously (by the Asynchronous Routing Engine). This means that messages
may be processed not 100% strictly in order. If disabled (as default) then the
Exchange is fully processed before the JmsConsumer will pickup the next message
from the JMS queue. Note [...]
| *camel.component.amqp.async-start-listener* | Whether to startup the
JmsConsumer message listener asynchronously, when starting a route. For example
if a JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover. This will cause Camel to block while
starting routes. By setting this option to true, you will let routes startup,
while the JmsConsumer connects to the JMS broker using a dedicated thread in
asynchronous mode. If this option [...]
diff --git
a/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
b/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
index 5c58a79..ba005a2 100644
---
a/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
+++
b/components-starter/camel-amqp-starter/src/main/java/org/apache/camel/component/amqp/springboot/AMQPComponentConfiguration.java
@@ -117,6 +117,19 @@ public class AMQPComponentConfiguration
*/
private String acknowledgementModeName = "AUTO_ACKNOWLEDGE";
/**
+ * Consumer priorities allow you to ensure that high priority consumers
+ * receive messages while they are active. Normally, active consumers
+ * connected to a queue receive messages from it in a round-robin fashion.
+ * When consumer priorities are in use, messages are delivered round-robin
+ * if multiple active consumers exist with the same high priority. Messages
+ * will only going to lower priority consumers when the high priority
+ * consumers do not have credit available to consume the message, or those
+ * high priority consumers have declined to accept the message (for
instance
+ * because it does not meet the criteria of any selectors associated with
+ * the consumer).
+ */
+ private Integer artemisConsumerPriority;
+ /**
* Whether the JmsConsumer processes the Exchange asynchronously. If
enabled
* then the JmsConsumer may pickup the next message from the JMS queue,
* while the previous message is being processed asynchronously (by the
@@ -848,6 +861,14 @@ public class AMQPComponentConfiguration
this.acknowledgementModeName = acknowledgementModeName;
}
+ public Integer getArtemisConsumerPriority() {
+ return artemisConsumerPriority;
+ }
+
+ public void setArtemisConsumerPriority(Integer artemisConsumerPriority) {
+ this.artemisConsumerPriority = artemisConsumerPriority;
+ }
+
public Boolean getAsyncConsumer() {
return asyncConsumer;
}
diff --git
a/components-starter/camel-jms-starter/src/main/docs/jms-starter.adoc
b/components-starter/camel-jms-starter/src/main/docs/jms-starter.adoc
index 9d83a19..2988df6 100644
--- a/components-starter/camel-jms-starter/src/main/docs/jms-starter.adoc
+++ b/components-starter/camel-jms-starter/src/main/docs/jms-starter.adoc
@@ -17,7 +17,7 @@ When using jms with Spring Boot make sure to use the
following Maven dependency
----
-The component supports 98 options, which are listed below.
+The component supports 99 options, which are listed below.
@@ -33,6 +33,7 @@ The component supports 98 options, which are listed below.
| *camel.component.jms.allow-reply-manager-quick-stop* | 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 fl [...]
| *camel.component.jms.allow-serialized-headers* | Controls whether or not to
include serialized headers. Applies only when transferExchange is true. This
requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level. | false | Boolean
| *camel.component.jms.always-copy-message* | If true, Camel will always make
a JMS message copy of the message when it is passed to the producer for
sending. Copying the message is needed in some situations, such as when a
replyToDestinationSelectorName is set (incidentally, Camel will set the
alwaysCopyMessage option to true, if a replyToDestinationSelectorName is set) |
false | Boolean
+| *camel.component.jms.artemis-consumer-priority* | Consumer priorities allow
you to ensure that high priority consumers receive messages while they are
active. Normally, active consumers connected to a queue receive messages from
it in a round-robin fashion. When consumer priorities are in use, messages are
delivered round-robin if multiple active consumers exist with the same high
priority. Messages will only going to lower priority consumers when the high
priority consumers do not hav [...]
| *camel.component.jms.artemis-streaming-enabled* | Whether optimizing for
Apache Artemis streaming mode. | true | Boolean
| *camel.component.jms.async-consumer* | Whether the JmsConsumer processes the
Exchange asynchronously. If enabled then the JmsConsumer may pickup the next
message from the JMS queue, while the previous message is being processed
asynchronously (by the Asynchronous Routing Engine). This means that messages
may be processed not 100% strictly in order. If disabled (as default) then the
Exchange is fully processed before the JmsConsumer will pickup the next message
from the JMS queue. Note [...]
| *camel.component.jms.async-start-listener* | Whether to startup the
JmsConsumer message listener asynchronously, when starting a route. For example
if a JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover. This will cause Camel to block while
starting routes. By setting this option to true, you will let routes startup,
while the JmsConsumer connects to the JMS broker using a dedicated thread in
asynchronous mode. If this option i [...]
diff --git
a/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
b/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
index 6e9bbca..7dab1d3 100644
---
a/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
+++
b/components-starter/camel-jms-starter/src/main/java/org/apache/camel/component/jms/springboot/JmsComponentConfiguration.java
@@ -101,6 +101,19 @@ public class JmsComponentConfiguration
*/
private String acknowledgementModeName = "AUTO_ACKNOWLEDGE";
/**
+ * Consumer priorities allow you to ensure that high priority consumers
+ * receive messages while they are active. Normally, active consumers
+ * connected to a queue receive messages from it in a round-robin fashion.
+ * When consumer priorities are in use, messages are delivered round-robin
+ * if multiple active consumers exist with the same high priority. Messages
+ * will only going to lower priority consumers when the high priority
+ * consumers do not have credit available to consume the message, or those
+ * high priority consumers have declined to accept the message (for
instance
+ * because it does not meet the criteria of any selectors associated with
+ * the consumer).
+ */
+ private Integer artemisConsumerPriority;
+ /**
* Whether the JmsConsumer processes the Exchange asynchronously. If
enabled
* then the JmsConsumer may pickup the next message from the JMS queue,
* while the previous message is being processed asynchronously (by the
@@ -824,6 +837,14 @@ public class JmsComponentConfiguration
this.acknowledgementModeName = acknowledgementModeName;
}
+ public Integer getArtemisConsumerPriority() {
+ return artemisConsumerPriority;
+ }
+
+ public void setArtemisConsumerPriority(Integer artemisConsumerPriority) {
+ this.artemisConsumerPriority = artemisConsumerPriority;
+ }
+
public Boolean getAsyncConsumer() {
return asyncConsumer;
}
diff --git a/docs/modules/ROOT/pages/activemq-starter.adoc
b/docs/modules/ROOT/pages/activemq-starter.adoc
index ebea80f..abde141 100644
--- a/docs/modules/ROOT/pages/activemq-starter.adoc
+++ b/docs/modules/ROOT/pages/activemq-starter.adoc
@@ -17,7 +17,7 @@ When using activemq with Spring Boot make sure to use the
following Maven depend
----
-The component supports 102 options, which are listed below.
+The component supports 103 options, which are listed below.
@@ -33,6 +33,7 @@ The component supports 102 options, which are listed below.
| *camel.component.activemq.allow-reply-manager-quick-stop* | 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 th [...]
| *camel.component.activemq.allow-serialized-headers* | Controls whether or
not to include serialized headers. Applies only when transferExchange is true.
This requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level. | false | Boolean
| *camel.component.activemq.always-copy-message* | If true, Camel will always
make a JMS message copy of the message when it is passed to the producer for
sending. Copying the message is needed in some situations, such as when a
replyToDestinationSelectorName is set (incidentally, Camel will set the
alwaysCopyMessage option to true, if a replyToDestinationSelectorName is set) |
false | Boolean
+| *camel.component.activemq.artemis-consumer-priority* | Consumer priorities
allow you to ensure that high priority consumers receive messages while they
are active. Normally, active consumers connected to a queue receive messages
from it in a round-robin fashion. When consumer priorities are in use, messages
are delivered round-robin if multiple active consumers exist with the same high
priority. Messages will only going to lower priority consumers when the high
priority consumers do no [...]
| *camel.component.activemq.artemis-streaming-enabled* | Whether optimizing
for Apache Artemis streaming mode. | true | Boolean
| *camel.component.activemq.async-consumer* | Whether the JmsConsumer
processes the Exchange asynchronously. If enabled then the JmsConsumer may
pickup the next message from the JMS queue, while the previous message is being
processed asynchronously (by the Asynchronous Routing Engine). This means that
messages may be processed not 100% strictly in order. If disabled (as default)
then the Exchange is fully processed before the JmsConsumer will pickup the
next message from the JMS queue. [...]
| *camel.component.activemq.async-start-listener* | Whether to startup the
JmsConsumer message listener asynchronously, when starting a route. For example
if a JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover. This will cause Camel to block while
starting routes. By setting this option to true, you will let routes startup,
while the JmsConsumer connects to the JMS broker using a dedicated thread in
asynchronous mode. If this opt [...]
diff --git a/docs/modules/ROOT/pages/amqp-starter.adoc
b/docs/modules/ROOT/pages/amqp-starter.adoc
index f1edf8f..8dc5866 100644
--- a/docs/modules/ROOT/pages/amqp-starter.adoc
+++ b/docs/modules/ROOT/pages/amqp-starter.adoc
@@ -17,7 +17,7 @@ When using amqp with Spring Boot make sure to use the
following Maven dependency
----
-The component supports 99 options, which are listed below.
+The component supports 100 options, which are listed below.
@@ -33,6 +33,7 @@ The component supports 99 options, which are listed below.
| *camel.component.amqp.allow-reply-manager-quick-stop* | 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 f [...]
| *camel.component.amqp.allow-serialized-headers* | Controls whether or not to
include serialized headers. Applies only when transferExchange is true. This
requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level. | false | Boolean
| *camel.component.amqp.always-copy-message* | If true, Camel will always make
a JMS message copy of the message when it is passed to the producer for
sending. Copying the message is needed in some situations, such as when a
replyToDestinationSelectorName is set (incidentally, Camel will set the
alwaysCopyMessage option to true, if a replyToDestinationSelectorName is set) |
false | Boolean
+| *camel.component.amqp.artemis-consumer-priority* | Consumer priorities allow
you to ensure that high priority consumers receive messages while they are
active. Normally, active consumers connected to a queue receive messages from
it in a round-robin fashion. When consumer priorities are in use, messages are
delivered round-robin if multiple active consumers exist with the same high
priority. Messages will only going to lower priority consumers when the high
priority consumers do not ha [...]
| *camel.component.amqp.artemis-streaming-enabled* | Whether optimizing for
Apache Artemis streaming mode. | true | Boolean
| *camel.component.amqp.async-consumer* | Whether the JmsConsumer processes
the Exchange asynchronously. If enabled then the JmsConsumer may pickup the
next message from the JMS queue, while the previous message is being processed
asynchronously (by the Asynchronous Routing Engine). This means that messages
may be processed not 100% strictly in order. If disabled (as default) then the
Exchange is fully processed before the JmsConsumer will pickup the next message
from the JMS queue. Note [...]
| *camel.component.amqp.async-start-listener* | Whether to startup the
JmsConsumer message listener asynchronously, when starting a route. For example
if a JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover. This will cause Camel to block while
starting routes. By setting this option to true, you will let routes startup,
while the JmsConsumer connects to the JMS broker using a dedicated thread in
asynchronous mode. If this option [...]
diff --git a/docs/modules/ROOT/pages/jms-starter.adoc
b/docs/modules/ROOT/pages/jms-starter.adoc
index 9d83a19..2988df6 100644
--- a/docs/modules/ROOT/pages/jms-starter.adoc
+++ b/docs/modules/ROOT/pages/jms-starter.adoc
@@ -17,7 +17,7 @@ When using jms with Spring Boot make sure to use the
following Maven dependency
----
-The component supports 98 options, which are listed below.
+The component supports 99 options, which are listed below.
@@ -33,6 +33,7 @@ The component supports 98 options, which are listed below.
| *camel.component.jms.allow-reply-manager-quick-stop* | 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 fl [...]
| *camel.component.jms.allow-serialized-headers* | Controls whether or not to
include serialized headers. Applies only when transferExchange is true. This
requires that the objects are serializable. Camel will exclude any
non-serializable objects and log it at WARN level. | false | Boolean
| *camel.component.jms.always-copy-message* | If true, Camel will always make
a JMS message copy of the message when it is passed to the producer for
sending. Copying the message is needed in some situations, such as when a
replyToDestinationSelectorName is set (incidentally, Camel will set the
alwaysCopyMessage option to true, if a replyToDestinationSelectorName is set) |
false | Boolean
+| *camel.component.jms.artemis-consumer-priority* | Consumer priorities allow
you to ensure that high priority consumers receive messages while they are
active. Normally, active consumers connected to a queue receive messages from
it in a round-robin fashion. When consumer priorities are in use, messages are
delivered round-robin if multiple active consumers exist with the same high
priority. Messages will only going to lower priority consumers when the high
priority consumers do not hav [...]
| *camel.component.jms.artemis-streaming-enabled* | Whether optimizing for
Apache Artemis streaming mode. | true | Boolean
| *camel.component.jms.async-consumer* | Whether the JmsConsumer processes the
Exchange asynchronously. If enabled then the JmsConsumer may pickup the next
message from the JMS queue, while the previous message is being processed
asynchronously (by the Asynchronous Routing Engine). This means that messages
may be processed not 100% strictly in order. If disabled (as default) then the
Exchange is fully processed before the JmsConsumer will pickup the next message
from the JMS queue. Note [...]
| *camel.component.jms.async-start-listener* | Whether to startup the
JmsConsumer message listener asynchronously, when starting a route. For example
if a JmsConsumer cannot get a connection to a remote JMS broker, then it may
block while retrying and/or failover. This will cause Camel to block while
starting routes. By setting this option to true, you will let routes startup,
while the JmsConsumer connects to the JMS broker using a dedicated thread in
asynchronous mode. If this option i [...]
