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.git
The following commit(s) were added to refs/heads/master by this push:
new f224a42 Fixed replyTo should be common option for jms component.
f224a42 is described below
commit f224a424e452bb8a878ad29277a78360d88f708f
Author: Claus Ibsen <[email protected]>
AuthorDate: Wed Sep 9 14:31:35 2020 +0200
Fixed replyTo should be common option for jms component.
---
.../apache/camel/component/activemq/activemq.json | 4 +-
.../src/main/docs/activemq-component.adoc | 4 +-
.../org/apache/camel/component/jms/jms.json | 4 +-
.../camel-jms/src/main/docs/jms-component.adoc | 4 +-
.../camel/component/jms/JmsConfiguration.java | 4 +-
.../dsl/ActivemqComponentBuilderFactory.java | 26 ++++++------
.../component/dsl/JmsComponentBuilderFactory.java | 26 ++++++------
.../dsl/ActiveMQEndpointBuilderFactory.java | 48 ++++++++++++++++------
.../endpoint/dsl/JmsEndpointBuilderFactory.java | 48 ++++++++++++++++------
9 files changed, 108 insertions(+), 60 deletions(-)
diff --git
a/components/camel-activemq/src/generated/resources/org/apache/camel/component/activemq/activemq.json
b/components/camel-activemq/src/generated/resources/org/apache/camel/component/activemq/activemq.json
index 766cf60..398cba2 100644
---
a/components/camel-activemq/src/generated/resources/org/apache/camel/component/activemq/activemq.json
+++
b/components/camel-activemq/src/generated/resources/org/apache/camel/component/activemq/activemq.json
@@ -29,6 +29,7 @@
"disableReplyTo": { "kind": "property", "displayName": "Disable Reply To",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies whether Camel
ignores the JMSReplyTo header in messages. If true, Camel does not send a reply
back to the destination spe [...]
"durableSubscriptionName": { "kind": "property", "displayName": "Durable
Subscription Name", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "The durable subscriber
name for specifying durable topic subscriptions. The clientId option must be
configured as well." },
"jmsMessageType": { "kind": "property", "displayName": "Jms Message Type",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.jms.JmsMessageType", "enum": [ "Bytes",
"Map", "Object", "Stream", "Text" ], "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Allows you to force the
use of a specific javax.jms.Message i [...]
+ "replyTo": { "kind": "property", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": 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, "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 that all the JMS consum [...]
"usePooledConnection": { "kind": "property", "displayName": "Use Pooled
Connection", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"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 than the default with [...]
"useSingleConnection": { "kind": "property", "displayName": "Use Single
Connection", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"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 rather than the defa [...]
@@ -39,7 +40,6 @@
"cacheLevelName": { "kind": "property", "displayName": "Cache Level Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "CACHE_AUTO", "CACHE_CONNECTION",
"CACHE_CONSUMER", "CACHE_NONE", "CACHE_SESSION" ], "deprecated": false,
"secret": false, "defaultValue": "CACHE_AUTO", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Sets the ca [...]
"concurrentConsumers": { "kind": "property", "displayName": "Concurrent
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies the default number of concurrent
consumers when consuming from JMS (not for request\/reply over JMS). See al
[...]
"maxConcurrentConsumers": { "kind": "property", "displayName": "Max
Concurrent Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies the maximum
number of concurrent consumers when consuming from JMS (not for request\/reply
over JMS). See also the maxMess [...]
- "replyTo": { "kind": "property", "displayName": "Reply To", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination, which overrides any incoming value of
Message.getJMSReplyTo()." },
"replyToDeliveryPersistent": { "kind": "property", "displayName": "Reply
To Delivery Persistent", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to use persistent delivery
by default for replies." },
"selector": { "kind": "property", "displayName": "Selector", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the JMS selector to
use" },
"subscriptionDurable": { "kind": "property", "displayName": "Subscription
Durable", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Set whether to make the subscription durable.
The durable subscription name to be used can be specified through [...]
@@ -132,6 +132,7 @@
"disableReplyTo": { "kind": "parameter", "displayName": "Disable Reply
To", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies whether Camel
ignores the JMSReplyTo header in messages. If true, Camel does not send a reply
back to the destination sp [...]
"durableSubscriptionName": { "kind": "parameter", "displayName": "Durable
Subscription Name", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "The durable subscriber
name for specifying durable topic subscriptions. The clientId option must be
configured as well." },
"jmsMessageType": { "kind": "parameter", "displayName": "Jms Message
Type", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.jms.JmsMessageType", "enum": [ "Bytes",
"Map", "Object", "Stream", "Text" ], "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Allows you to force the
use of a specific javax.jms.Message [...]
+ "replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": 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, "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 that all the JMS consu [...]
"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, "secret": false, "defaultValue":
"AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration" [...]
"asyncConsumer": { "kind": "parameter", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": 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
pickup the next message [...]
@@ -140,7 +141,6 @@
"cacheLevelName": { "kind": "parameter", "displayName": "Cache Level
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "CACHE_AUTO",
"CACHE_CONNECTION", "CACHE_CONSUMER", "CACHE_NONE", "CACHE_SESSION" ],
"deprecated": false, "secret": false, "defaultValue": "CACHE_AUTO",
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the c [...]
"concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies the default number of concurrent
consumers when consuming from JMS (not for request\/reply over JMS). See a [...]
"maxConcurrentConsumers": { "kind": "parameter", "displayName": "Max
Concurrent Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies the maximum
number of concurrent consumers when consuming from JMS (not for request\/reply
over JMS). See also the maxMes [...]
- "replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination, which overrides any incoming value of
Message.getJMSReplyTo()." },
"replyToDeliveryPersistent": { "kind": "parameter", "displayName": "Reply
To Delivery Persistent", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to use persistent delivery
by default for replies." },
"selector": { "kind": "parameter", "displayName": "Selector", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the JMS selector to
use" },
"subscriptionDurable": { "kind": "parameter", "displayName": "Subscription
Durable", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Set whether to make the subscription durable.
The durable subscription name to be used can be specified through [...]
diff --git a/components/camel-activemq/src/main/docs/activemq-component.adoc
b/components/camel-activemq/src/main/docs/activemq-component.adoc
index 27288cf..77e8514 100644
--- a/components/camel-activemq/src/main/docs/activemq-component.adoc
+++ b/components/camel-activemq/src/main/docs/activemq-component.adoc
@@ -65,6 +65,7 @@ The ActiveMQ component supports 100 options, which are listed
below.
| *disableReplyTo* (common) | Specifies whether Camel ignores the JMSReplyTo
header in messages. If true, Camel does not send a reply back to the
destination specified in the JMSReplyTo header. You can use this option if you
want Camel to consume from a route and you do not want Camel to automatically
send back a reply message because another component in your code handles the
reply message. You can also use this option if you want to use Camel as a proxy
between different message broker [...]
| *durableSubscriptionName* (common) | The durable subscriber name for
specifying durable topic subscriptions. The clientId option must be configured
as well. | | String
| *jmsMessageType* (common) | Allows you to force the use of a specific
javax.jms.Message implementation for sending JMS messages. Possible values are:
Bytes, Map, Object, Stream, Text. By default, Camel would determine which JMS
message type to use from the In body type. This option allows you to specify
it. There are 5 enums and the value can be one of: Bytes, Map, Object, Stream,
Text | | JmsMessageType
+| *replyTo* (common) | Provides an explicit ReplyTo destination (overrides any
incoming value of Message.getJMSReplyTo() in consumer). | | String
| *testConnectionOnStartup* (common) | Specifies whether to test the
connection on startup. This ensures that when Camel starts that all the JMS
consumers have a valid connection to the JMS broker. If a connection cannot be
granted then Camel throws an exception on startup. This ensures that Camel is
not started with failed connections. The JMS producers is tested as well. |
false | boolean
| *usePooledConnection* (common) | 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 than
the default with the Spring JmsTemplate which will create a new connection,
session, producer for each message then close them all down again. The default
value is true. | true | boolean
| *useSingleConnection* (common) | 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 rather than
the default with the Spring JmsTemplate which will create a new connection,
session, producer for each message then close them all down again. The default
value is false and a pooled connection is used by default. | false | boolean
@@ -75,7 +76,6 @@ The ActiveMQ component supports 100 options, which are listed
below.
| *cacheLevelName* (consumer) | Sets the cache level by name for the
underlying JMS resources. Possible values are: CACHE_AUTO, CACHE_CONNECTION,
CACHE_CONSUMER, CACHE_NONE, and CACHE_SESSION. The default setting is
CACHE_AUTO. See the Spring documentation and Transactions Cache Levels for more
information. There are 5 enums and the value can be one of: CACHE_AUTO,
CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION | CACHE_AUTO |
String
| *concurrentConsumers* (consumer) | Specifies the default number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToConcurrentConsumers is used to control number of concurrent consumers on
the reply message listener. | 1 | int
| *maxConcurrentConsumers* (consumer) | Specifies the maximum number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToMaxConcurrentConsumers is used to control number of concurrent consumers
on the reply message listener. | | int
-| *replyTo* (consumer) | Provides an explicit ReplyTo destination, which
overrides any incoming value of Message.getJMSReplyTo(). | | String
| *replyToDeliveryPersistent* (consumer) | Specifies whether to use persistent
delivery by default for replies. | true | boolean
| *selector* (consumer) | Sets the JMS selector to use | | String
| *subscriptionDurable* (consumer) | Set whether to make the subscription
durable. The durable subscription name to be used can be specified through the
subscriptionName property. Default is false. Set this to true to register a
durable subscription, typically in combination with a subscriptionName value
(unless your message listener class name is good enough as subscription name).
Only makes sense when listening to a topic (pub-sub domain), therefore this
method switches the pubSubDomai [...]
@@ -196,6 +196,7 @@ with the following path and query parameters:
| *disableReplyTo* (common) | Specifies whether Camel ignores the JMSReplyTo
header in messages. If true, Camel does not send a reply back to the
destination specified in the JMSReplyTo header. You can use this option if you
want Camel to consume from a route and you do not want Camel to automatically
send back a reply message because another component in your code handles the
reply message. You can also use this option if you want to use Camel as a proxy
between different message broker [...]
| *durableSubscriptionName* (common) | The durable subscriber name for
specifying durable topic subscriptions. The clientId option must be configured
as well. | | String
| *jmsMessageType* (common) | Allows you to force the use of a specific
javax.jms.Message implementation for sending JMS messages. Possible values are:
Bytes, Map, Object, Stream, Text. By default, Camel would determine which JMS
message type to use from the In body type. This option allows you to specify
it. There are 5 enums and the value can be one of: Bytes, Map, Object, Stream,
Text | | JmsMessageType
+| *replyTo* (common) | Provides an explicit ReplyTo destination (overrides any
incoming value of Message.getJMSReplyTo() in consumer). | | String
| *testConnectionOnStartup* (common) | Specifies whether to test the
connection on startup. This ensures that when Camel starts that all the JMS
consumers have a valid connection to the JMS broker. If a connection cannot be
granted then Camel throws an exception on startup. This ensures that Camel is
not started with failed connections. The JMS producers is tested as well. |
false | boolean
| *acknowledgementModeName* (consumer) | The JMS acknowledgement name, which
is one of: SESSION_TRANSACTED, CLIENT_ACKNOWLEDGE, AUTO_ACKNOWLEDGE,
DUPS_OK_ACKNOWLEDGE. There are 4 enums and the value can be one of:
SESSION_TRANSACTED, CLIENT_ACKNOWLEDGE, AUTO_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE |
AUTO_ACKNOWLEDGE | String
| *asyncConsumer* (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 if transac [...]
@@ -204,7 +205,6 @@ with the following path and query parameters:
| *cacheLevelName* (consumer) | Sets the cache level by name for the
underlying JMS resources. Possible values are: CACHE_AUTO, CACHE_CONNECTION,
CACHE_CONSUMER, CACHE_NONE, and CACHE_SESSION. The default setting is
CACHE_AUTO. See the Spring documentation and Transactions Cache Levels for more
information. There are 5 enums and the value can be one of: CACHE_AUTO,
CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION | CACHE_AUTO |
String
| *concurrentConsumers* (consumer) | Specifies the default number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToConcurrentConsumers is used to control number of concurrent consumers on
the reply message listener. | 1 | int
| *maxConcurrentConsumers* (consumer) | Specifies the maximum number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToMaxConcurrentConsumers is used to control number of concurrent consumers
on the reply message listener. | | int
-| *replyTo* (consumer) | Provides an explicit ReplyTo destination, which
overrides any incoming value of Message.getJMSReplyTo(). | | String
| *replyToDeliveryPersistent* (consumer) | Specifies whether to use persistent
delivery by default for replies. | true | boolean
| *selector* (consumer) | Sets the JMS selector to use | | String
| *subscriptionDurable* (consumer) | Set whether to make the subscription
durable. The durable subscription name to be used can be specified through the
subscriptionName property. Default is false. Set this to true to register a
durable subscription, typically in combination with a subscriptionName value
(unless your message listener class name is good enough as subscription name).
Only makes sense when listening to a topic (pub-sub domain), therefore this
method switches the pubSubDomai [...]
diff --git
a/components/camel-jms/src/generated/resources/org/apache/camel/component/jms/jms.json
b/components/camel-jms/src/generated/resources/org/apache/camel/component/jms/jms.json
index b304941..37935c1 100644
---
a/components/camel-jms/src/generated/resources/org/apache/camel/component/jms/jms.json
+++
b/components/camel-jms/src/generated/resources/org/apache/camel/component/jms/jms.json
@@ -29,6 +29,7 @@
"disableReplyTo": { "kind": "property", "displayName": "Disable Reply To",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies whether Camel
ignores the JMSReplyTo header in messages. If true, Camel does not send a reply
back to the destination spe [...]
"durableSubscriptionName": { "kind": "property", "displayName": "Durable
Subscription Name", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "The durable subscriber
name for specifying durable topic subscriptions. The clientId option must be
configured as well." },
"jmsMessageType": { "kind": "property", "displayName": "Jms Message Type",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.jms.JmsMessageType", "enum": [ "Bytes",
"Map", "Object", "Stream", "Text" ], "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Allows you to force the
use of a specific javax.jms.Message i [...]
+ "replyTo": { "kind": "property", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": 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, "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 that all the JMS consum [...]
"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, "secret": false, "defaultValue":
"AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", [...]
"asyncConsumer": { "kind": "property", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": 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
pickup the next message f [...]
@@ -37,7 +38,6 @@
"cacheLevelName": { "kind": "property", "displayName": "Cache Level Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "CACHE_AUTO", "CACHE_CONNECTION",
"CACHE_CONSUMER", "CACHE_NONE", "CACHE_SESSION" ], "deprecated": false,
"secret": false, "defaultValue": "CACHE_AUTO", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Sets the ca [...]
"concurrentConsumers": { "kind": "property", "displayName": "Concurrent
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies the default number of concurrent
consumers when consuming from JMS (not for request\/reply over JMS). See al
[...]
"maxConcurrentConsumers": { "kind": "property", "displayName": "Max
Concurrent Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies the maximum
number of concurrent consumers when consuming from JMS (not for request\/reply
over JMS). See also the maxMess [...]
- "replyTo": { "kind": "property", "displayName": "Reply To", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination, which overrides any incoming value of
Message.getJMSReplyTo()." },
"replyToDeliveryPersistent": { "kind": "property", "displayName": "Reply
To Delivery Persistent", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to use persistent delivery
by default for replies." },
"selector": { "kind": "property", "displayName": "Selector", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the JMS selector to
use" },
"subscriptionDurable": { "kind": "property", "displayName": "Subscription
Durable", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Set whether to make the subscription durable.
The durable subscription name to be used can be specified through [...]
@@ -129,6 +129,7 @@
"disableReplyTo": { "kind": "parameter", "displayName": "Disable Reply
To", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies whether Camel
ignores the JMSReplyTo header in messages. If true, Camel does not send a reply
back to the destination sp [...]
"durableSubscriptionName": { "kind": "parameter", "displayName": "Durable
Subscription Name", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "The durable subscriber
name for specifying durable topic subscriptions. The clientId option must be
configured as well." },
"jmsMessageType": { "kind": "parameter", "displayName": "Jms Message
Type", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.jms.JmsMessageType", "enum": [ "Bytes",
"Map", "Object", "Stream", "Text" ], "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Allows you to force the
use of a specific javax.jms.Message [...]
+ "replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": 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, "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 that all the JMS consu [...]
"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, "secret": false, "defaultValue":
"AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration" [...]
"asyncConsumer": { "kind": "parameter", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": 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
pickup the next message [...]
@@ -137,7 +138,6 @@
"cacheLevelName": { "kind": "parameter", "displayName": "Cache Level
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "CACHE_AUTO",
"CACHE_CONNECTION", "CACHE_CONSUMER", "CACHE_NONE", "CACHE_SESSION" ],
"deprecated": false, "secret": false, "defaultValue": "CACHE_AUTO",
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the c [...]
"concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "1", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies the default number of concurrent
consumers when consuming from JMS (not for request\/reply over JMS). See a [...]
"maxConcurrentConsumers": { "kind": "parameter", "displayName": "Max
Concurrent Consumers", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Specifies the maximum
number of concurrent consumers when consuming from JMS (not for request\/reply
over JMS). See also the maxMes [...]
- "replyTo": { "kind": "parameter", "displayName": "Reply To", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Provides an explicit
ReplyTo destination, which overrides any incoming value of
Message.getJMSReplyTo()." },
"replyToDeliveryPersistent": { "kind": "parameter", "displayName": "Reply
To Delivery Persistent", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether to use persistent delivery
by default for replies." },
"selector": { "kind": "parameter", "displayName": "Selector", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass": "org.apache.camel.component.jms.JmsConfiguration",
"configurationField": "configuration", "description": "Sets the JMS selector to
use" },
"subscriptionDurable": { "kind": "parameter", "displayName": "Subscription
Durable", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Set whether to make the subscription durable.
The durable subscription name to be used can be specified through [...]
diff --git a/components/camel-jms/src/main/docs/jms-component.adoc
b/components/camel-jms/src/main/docs/jms-component.adoc
index b5c5930..5db62b5 100644
--- a/components/camel-jms/src/main/docs/jms-component.adoc
+++ b/components/camel-jms/src/main/docs/jms-component.adoc
@@ -198,6 +198,7 @@ The JMS component supports 96 options, which are listed
below.
| *disableReplyTo* (common) | Specifies whether Camel ignores the JMSReplyTo
header in messages. If true, Camel does not send a reply back to the
destination specified in the JMSReplyTo header. You can use this option if you
want Camel to consume from a route and you do not want Camel to automatically
send back a reply message because another component in your code handles the
reply message. You can also use this option if you want to use Camel as a proxy
between different message broker [...]
| *durableSubscriptionName* (common) | The durable subscriber name for
specifying durable topic subscriptions. The clientId option must be configured
as well. | | String
| *jmsMessageType* (common) | Allows you to force the use of a specific
javax.jms.Message implementation for sending JMS messages. Possible values are:
Bytes, Map, Object, Stream, Text. By default, Camel would determine which JMS
message type to use from the In body type. This option allows you to specify
it. There are 5 enums and the value can be one of: Bytes, Map, Object, Stream,
Text | | JmsMessageType
+| *replyTo* (common) | Provides an explicit ReplyTo destination (overrides any
incoming value of Message.getJMSReplyTo() in consumer). | | String
| *testConnectionOnStartup* (common) | Specifies whether to test the
connection on startup. This ensures that when Camel starts that all the JMS
consumers have a valid connection to the JMS broker. If a connection cannot be
granted then Camel throws an exception on startup. This ensures that Camel is
not started with failed connections. The JMS producers is tested as well. |
false | boolean
| *acknowledgementModeName* (consumer) | The JMS acknowledgement name, which
is one of: SESSION_TRANSACTED, CLIENT_ACKNOWLEDGE, AUTO_ACKNOWLEDGE,
DUPS_OK_ACKNOWLEDGE. There are 4 enums and the value can be one of:
SESSION_TRANSACTED, CLIENT_ACKNOWLEDGE, AUTO_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE |
AUTO_ACKNOWLEDGE | String
| *asyncConsumer* (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 if transac [...]
@@ -206,7 +207,6 @@ The JMS component supports 96 options, which are listed
below.
| *cacheLevelName* (consumer) | Sets the cache level by name for the
underlying JMS resources. Possible values are: CACHE_AUTO, CACHE_CONNECTION,
CACHE_CONSUMER, CACHE_NONE, and CACHE_SESSION. The default setting is
CACHE_AUTO. See the Spring documentation and Transactions Cache Levels for more
information. There are 5 enums and the value can be one of: CACHE_AUTO,
CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION | CACHE_AUTO |
String
| *concurrentConsumers* (consumer) | Specifies the default number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToConcurrentConsumers is used to control number of concurrent consumers on
the reply message listener. | 1 | int
| *maxConcurrentConsumers* (consumer) | Specifies the maximum number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToMaxConcurrentConsumers is used to control number of concurrent consumers
on the reply message listener. | | int
-| *replyTo* (consumer) | Provides an explicit ReplyTo destination, which
overrides any incoming value of Message.getJMSReplyTo(). | | String
| *replyToDeliveryPersistent* (consumer) | Specifies whether to use persistent
delivery by default for replies. | true | boolean
| *selector* (consumer) | Sets the JMS selector to use | | String
| *subscriptionDurable* (consumer) | Set whether to make the subscription
durable. The durable subscription name to be used can be specified through the
subscriptionName property. Default is false. Set this to true to register a
durable subscription, typically in combination with a subscriptionName value
(unless your message listener class name is good enough as subscription name).
Only makes sense when listening to a topic (pub-sub domain), therefore this
method switches the pubSubDomai [...]
@@ -340,6 +340,7 @@ with the following path and query parameters:
| *disableReplyTo* (common) | Specifies whether Camel ignores the JMSReplyTo
header in messages. If true, Camel does not send a reply back to the
destination specified in the JMSReplyTo header. You can use this option if you
want Camel to consume from a route and you do not want Camel to automatically
send back a reply message because another component in your code handles the
reply message. You can also use this option if you want to use Camel as a proxy
between different message broker [...]
| *durableSubscriptionName* (common) | The durable subscriber name for
specifying durable topic subscriptions. The clientId option must be configured
as well. | | String
| *jmsMessageType* (common) | Allows you to force the use of a specific
javax.jms.Message implementation for sending JMS messages. Possible values are:
Bytes, Map, Object, Stream, Text. By default, Camel would determine which JMS
message type to use from the In body type. This option allows you to specify
it. There are 5 enums and the value can be one of: Bytes, Map, Object, Stream,
Text | | JmsMessageType
+| *replyTo* (common) | Provides an explicit ReplyTo destination (overrides any
incoming value of Message.getJMSReplyTo() in consumer). | | String
| *testConnectionOnStartup* (common) | Specifies whether to test the
connection on startup. This ensures that when Camel starts that all the JMS
consumers have a valid connection to the JMS broker. If a connection cannot be
granted then Camel throws an exception on startup. This ensures that Camel is
not started with failed connections. The JMS producers is tested as well. |
false | boolean
| *acknowledgementModeName* (consumer) | The JMS acknowledgement name, which
is one of: SESSION_TRANSACTED, CLIENT_ACKNOWLEDGE, AUTO_ACKNOWLEDGE,
DUPS_OK_ACKNOWLEDGE. There are 4 enums and the value can be one of:
SESSION_TRANSACTED, CLIENT_ACKNOWLEDGE, AUTO_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE |
AUTO_ACKNOWLEDGE | String
| *asyncConsumer* (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 if transac [...]
@@ -348,7 +349,6 @@ with the following path and query parameters:
| *cacheLevelName* (consumer) | Sets the cache level by name for the
underlying JMS resources. Possible values are: CACHE_AUTO, CACHE_CONNECTION,
CACHE_CONSUMER, CACHE_NONE, and CACHE_SESSION. The default setting is
CACHE_AUTO. See the Spring documentation and Transactions Cache Levels for more
information. There are 5 enums and the value can be one of: CACHE_AUTO,
CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION | CACHE_AUTO |
String
| *concurrentConsumers* (consumer) | Specifies the default number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToConcurrentConsumers is used to control number of concurrent consumers on
the reply message listener. | 1 | int
| *maxConcurrentConsumers* (consumer) | Specifies the maximum number of
concurrent consumers when consuming from JMS (not for request/reply over JMS).
See also the maxMessagesPerTask option to control dynamic scaling up/down of
threads. When doing request/reply over JMS then the option
replyToMaxConcurrentConsumers is used to control number of concurrent consumers
on the reply message listener. | | int
-| *replyTo* (consumer) | Provides an explicit ReplyTo destination, which
overrides any incoming value of Message.getJMSReplyTo(). | | String
| *replyToDeliveryPersistent* (consumer) | Specifies whether to use persistent
delivery by default for replies. | true | boolean
| *selector* (consumer) | Sets the JMS selector to use | | String
| *subscriptionDurable* (consumer) | Set whether to make the subscription
durable. The durable subscription name to be used can be specified through the
subscriptionName property. Default is false. Set this to true to register a
durable subscription, typically in combination with a subscriptionName value
(unless your message listener class name is good enough as subscription name).
Only makes sense when listening to a topic (pub-sub domain), therefore this
method switches the pubSubDomai [...]
diff --git
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
index 05e1bc1..ec623d5 100644
---
a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
+++
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
@@ -319,8 +319,8 @@ public class JmsConfiguration implements Cloneable {
@UriParam(label = "advanced",
description = "Specifies whether JMSMessageID should always be
used as JMSCorrelationID for InOut messages.")
private boolean useMessageIDAsCorrelationID;
- @UriParam(label = "consumer",
- description = "Provides an explicit ReplyTo destination, which
overrides any incoming value of Message.getJMSReplyTo().")
+ @UriParam(label = "common",
+ description = "Provides an explicit ReplyTo destination
(overrides any incoming value of Message.getJMSReplyTo() in consumer).")
private String replyTo;
@UriParam(label = "producer,advanced",
description = "Sets the JMS Selector using the fixed name to be
used so you can filter out your own replies"
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/ActivemqComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/ActivemqComponentBuilderFactory.java
index bfebaf5..6477df7 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/ActivemqComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/ActivemqComponentBuilderFactory.java
@@ -141,6 +141,18 @@ public interface ActivemqComponentBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default ActivemqComponentBuilder replyTo(java.lang.String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
@@ -306,18 +318,6 @@ public interface ActivemqComponentBuilderFactory {
return this;
}
/**
- * Provides an explicit ReplyTo destination, which overrides any
- * incoming value of Message.getJMSReplyTo().
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- */
- default ActivemqComponentBuilder replyTo(java.lang.String replyTo) {
- doSetProperty("replyTo", replyTo);
- return this;
- }
- /**
* Specifies whether to use persistent delivery by default for replies.
*
* The option is a: <code>boolean</code> type.
@@ -1690,6 +1690,7 @@ public interface ActivemqComponentBuilderFactory {
case "disableReplyTo":
getOrCreateConfiguration((ActiveMQComponent)
component).setDisableReplyTo((boolean) value); return true;
case "durableSubscriptionName":
getOrCreateConfiguration((ActiveMQComponent)
component).setDurableSubscriptionName((java.lang.String) value); return true;
case "jmsMessageType":
getOrCreateConfiguration((ActiveMQComponent)
component).setJmsMessageType((org.apache.camel.component.jms.JmsMessageType)
value); return true;
+ case "replyTo": getOrCreateConfiguration((ActiveMQComponent)
component).setReplyTo((java.lang.String) value); return true;
case "testConnectionOnStartup":
getOrCreateConfiguration((ActiveMQComponent)
component).setTestConnectionOnStartup((boolean) value); return true;
case "usePooledConnection": ((ActiveMQComponent)
component).setUsePooledConnection((boolean) value); return true;
case "useSingleConnection": ((ActiveMQComponent)
component).setUseSingleConnection((boolean) value); return true;
@@ -1700,7 +1701,6 @@ public interface ActivemqComponentBuilderFactory {
case "cacheLevelName":
getOrCreateConfiguration((ActiveMQComponent)
component).setCacheLevelName((java.lang.String) value); return true;
case "concurrentConsumers":
getOrCreateConfiguration((ActiveMQComponent)
component).setConcurrentConsumers((int) value); return true;
case "maxConcurrentConsumers":
getOrCreateConfiguration((ActiveMQComponent)
component).setMaxConcurrentConsumers((int) value); return true;
- case "replyTo": getOrCreateConfiguration((ActiveMQComponent)
component).setReplyTo((java.lang.String) value); return true;
case "replyToDeliveryPersistent":
getOrCreateConfiguration((ActiveMQComponent)
component).setReplyToDeliveryPersistent((boolean) value); return true;
case "selector": getOrCreateConfiguration((ActiveMQComponent)
component).setSelector((java.lang.String) value); return true;
case "subscriptionDurable":
getOrCreateConfiguration((ActiveMQComponent)
component).setSubscriptionDurable((boolean) value); return true;
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/JmsComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/JmsComponentBuilderFactory.java
index 94c4817..3bf0ecb 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/JmsComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/JmsComponentBuilderFactory.java
@@ -124,6 +124,18 @@ public interface JmsComponentBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default JmsComponentBuilder replyTo(java.lang.String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
@@ -251,18 +263,6 @@ public interface JmsComponentBuilderFactory {
return this;
}
/**
- * Provides an explicit ReplyTo destination, which overrides any
- * incoming value of Message.getJMSReplyTo().
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- */
- default JmsComponentBuilder replyTo(java.lang.String replyTo) {
- doSetProperty("replyTo", replyTo);
- return this;
- }
- /**
* Specifies whether to use persistent delivery by default for replies.
*
* The option is a: <code>boolean</code> type.
@@ -1608,6 +1608,7 @@ public interface JmsComponentBuilderFactory {
case "disableReplyTo": getOrCreateConfiguration((JmsComponent)
component).setDisableReplyTo((boolean) value); return true;
case "durableSubscriptionName":
getOrCreateConfiguration((JmsComponent)
component).setDurableSubscriptionName((java.lang.String) value); return true;
case "jmsMessageType": getOrCreateConfiguration((JmsComponent)
component).setJmsMessageType((org.apache.camel.component.jms.JmsMessageType)
value); return true;
+ case "replyTo": getOrCreateConfiguration((JmsComponent)
component).setReplyTo((java.lang.String) value); return true;
case "testConnectionOnStartup":
getOrCreateConfiguration((JmsComponent)
component).setTestConnectionOnStartup((boolean) value); return true;
case "acknowledgementModeName":
getOrCreateConfiguration((JmsComponent)
component).setAcknowledgementModeName((java.lang.String) value); return true;
case "asyncConsumer": getOrCreateConfiguration((JmsComponent)
component).setAsyncConsumer((boolean) value); return true;
@@ -1616,7 +1617,6 @@ public interface JmsComponentBuilderFactory {
case "cacheLevelName": getOrCreateConfiguration((JmsComponent)
component).setCacheLevelName((java.lang.String) value); return true;
case "concurrentConsumers":
getOrCreateConfiguration((JmsComponent) component).setConcurrentConsumers((int)
value); return true;
case "maxConcurrentConsumers":
getOrCreateConfiguration((JmsComponent)
component).setMaxConcurrentConsumers((int) value); return true;
- case "replyTo": getOrCreateConfiguration((JmsComponent)
component).setReplyTo((java.lang.String) value); return true;
case "replyToDeliveryPersistent":
getOrCreateConfiguration((JmsComponent)
component).setReplyToDeliveryPersistent((boolean) value); return true;
case "selector": getOrCreateConfiguration((JmsComponent)
component).setSelector((java.lang.String) value); return true;
case "subscriptionDurable":
getOrCreateConfiguration((JmsComponent)
component).setSubscriptionDurable((boolean) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
index 60b11a4..e85bb36 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
@@ -174,6 +174,18 @@ public interface ActiveMQEndpointBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default ActiveMQEndpointConsumerBuilder replyTo(String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
@@ -401,18 +413,6 @@ public interface ActiveMQEndpointBuilderFactory {
return this;
}
/**
- * Provides an explicit ReplyTo destination, which overrides any
- * incoming value of Message.getJMSReplyTo().
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- */
- default ActiveMQEndpointConsumerBuilder replyTo(String replyTo) {
- doSetProperty("replyTo", replyTo);
- return this;
- }
- /**
* Specifies whether to use persistent delivery by default for replies.
*
* The option is a: <code>boolean</code> type.
@@ -2304,6 +2304,18 @@ public interface ActiveMQEndpointBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default ActiveMQEndpointProducerBuilder replyTo(String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
@@ -4400,6 +4412,18 @@ public interface ActiveMQEndpointBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default ActiveMQEndpointBuilder replyTo(String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
index 1765be2..4d60a86 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
@@ -170,6 +170,18 @@ public interface JmsEndpointBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default JmsEndpointConsumerBuilder replyTo(String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
@@ -394,18 +406,6 @@ public interface JmsEndpointBuilderFactory {
return this;
}
/**
- * Provides an explicit ReplyTo destination, which overrides any
- * incoming value of Message.getJMSReplyTo().
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- */
- default JmsEndpointConsumerBuilder replyTo(String replyTo) {
- doSetProperty("replyTo", replyTo);
- return this;
- }
- /**
* Specifies whether to use persistent delivery by default for replies.
*
* The option is a: <code>boolean</code> type.
@@ -2294,6 +2294,18 @@ public interface JmsEndpointBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default JmsEndpointProducerBuilder replyTo(String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
@@ -4382,6 +4394,18 @@ public interface JmsEndpointBuilderFactory {
return this;
}
/**
+ * Provides an explicit ReplyTo destination (overrides any incoming
+ * value of Message.getJMSReplyTo() in consumer).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ */
+ default JmsEndpointBuilder replyTo(String replyTo) {
+ doSetProperty("replyTo", replyTo);
+ return this;
+ }
+ /**
* Specifies whether to test the connection on startup. This ensures
* that when Camel starts that all the JMS consumers have a valid
* connection to the JMS broker. If a connection cannot be granted then
