This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 0ecd055 Regen
0ecd055 is described below
commit 0ecd055e4f6c1b16ea05a9f5f91fbc8d9ab6163a
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Jan 27 09:19:20 2022 +0100
Regen
---
.../camel/catalog/components/dynamic-router.json | 25 +-
.../dsl/DynamicRouterComponentBuilderFactory.java | 23 --
.../src/generated/resources/metadata.json | 3 +-
.../builder/endpoint/StaticEndpointBuilders.java | 14 +
.../dsl/DynamicRouterEndpointBuilderFactory.java | 393 ++++++---------------
.../EndpointConsumerDeserializersResolver.java | 1 -
6 files changed, 131 insertions(+), 328 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dynamic-router.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dynamic-router.json
index 8b02990..9cf0104 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dynamic-router.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dynamic-router.json
@@ -15,27 +15,30 @@
"scheme": "dynamic-router",
"extendsScheme": "",
"syntax": "dynamic-router:channel",
+ "alternativeSyntax":
"dynamic-router:channel\/controlAction\/subscribeChannel",
"async": false,
"api": false,
"consumerOnly": false,
- "producerOnly": false,
+ "producerOnly": true,
"lenientProperties": false
},
"componentProperties": {
- "bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
},
"properties": {
- "channel": { "kind": "path", "displayName": "Channel", "group": "common",
"label": "common", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Channel of the Dynamic Router" },
- "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
- "exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
- "exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
- "block": { "kind": "parameter", "displayName": "Block", "group":
"producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Flag that determines if the
producer should block while waiting for a consumer." },
- "failIfNoConsumers": { "kind": "parameter", "displayName": "Fail If No
Consumers", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": true, "description": "Flag to fail if
there are no consumers." },
+ "channel": { "kind": "path", "displayName": "Channel", "group": "common",
"label": "common", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "Channel of the Dynamic
Router" },
+ "controlAction": { "kind": "path", "displayName": "Control Action",
"group": "control", "label": "control", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "subscribe", "unsubscribe" ],
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "Control channel action:
subscribe or unsub [...]
+ "subscribeChannel": { "kind": "path", "displayName": "Subscribe Channel",
"group": "control", "label": "control", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "The channel to subscribe
to" },
+ "recipientMode": { "kind": "parameter", "displayName": "Recipient Mode",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "firstMatch", "allMatch" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"firstMatch", "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "Recipient mode:
firstMatch or allM [...]
+ "synchronous": { "kind": "parameter", "displayName": "Synchronous",
"group": "common", "label": "common", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "Flag to ensure
synchronous processing." },
+ "warnDroppedMessage": { "kind": "parameter", "displayName": "Warn Dropped
Message", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "Flag to log a warning if
no predicates match for an exchange." },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during sta [...]
- "timeout": { "kind": "parameter", "displayName": "Timeout", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 30000, "description": "The time limit, in milliseconds,
if\/when the producer blocks while waiting for a consumer." },
- "warnDroppedMessage": { "kind": "parameter", "displayName": "Warn Dropped
Message", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Flag to log a warning
if no predicates match for an exchange." },
- "synchronous": { "kind": "parameter", "displayName": "Synchronous",
"group": "advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Flag to ensure synchronous
processing." }
+ "destinationUri": { "kind": "parameter", "displayName": "Destination Uri",
"group": "control", "label": "control", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "The destination URI for
exchanges that match." },
+ "expressionLanguage": { "kind": "parameter", "displayName": "Expression
Language", "group": "control", "label": "control", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "simple", "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "The subscription
predicate language." },
+ "predicate": { "kind": "parameter", "displayName": "Predicate", "group":
"control", "label": "control", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "The subscription
predicate." },
+ "predicateBean": { "kind": "parameter", "displayName": "Predicate Bean",
"group": "control", "label": "control", "required": false, "type": "object",
"javaType": "org.apache.camel.Predicate", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "A Predicate instance in
the registry." },
+ "priority": { "kind": "parameter", "displayName": "Priority", "group":
"control", "label": "control", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "The subscription
priority." },
+ "subscriptionId": { "kind": "parameter", "displayName": "Subscription Id",
"group": "control", "label": "control", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dynamicrouter.DynamicRouterConfiguration",
"configurationField": "configuration", "description": "The subscription ID; if
unspecified, one will be assigned and returned." }
}
}
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DynamicRouterComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DynamicRouterComponentBuilderFactory.java
index f74fe83..0a253b2 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DynamicRouterComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DynamicRouterComponentBuilderFactory.java
@@ -53,28 +53,6 @@ public interface DynamicRouterComponentBuilderFactory {
extends
ComponentBuilder<DynamicRouterComponent> {
/**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions occurred while the consumer is trying to
- * pickup incoming messages, or the likes, will now be processed as a
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default DynamicRouterComponentBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes
to
* startup in situations where a producer may otherwise fail during
@@ -136,7 +114,6 @@ public interface DynamicRouterComponentBuilderFactory {
String name,
Object value) {
switch (name) {
- case "bridgeErrorHandler": ((DynamicRouterComponent)
component).setBridgeErrorHandler((boolean) value); return true;
case "lazyStartProducer": ((DynamicRouterComponent)
component).setLazyStartProducer((boolean) value); return true;
case "autowiredEnabled": ((DynamicRouterComponent)
component).setAutowiredEnabled((boolean) value); return true;
default: return false;
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json
b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index 1678aa1..97d1caa 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -2121,10 +2121,11 @@
"scheme": "dynamic-router",
"extendsScheme": "",
"syntax": "dynamic-router:channel",
+ "alternativeSyntax":
"dynamic-router:channel\/controlAction\/subscribeChannel",
"async": false,
"api": false,
"consumerOnly": false,
- "producerOnly": false,
+ "producerOnly": true,
"lenientProperties": false
},
"EhcacheComponentBuilderFactory": {
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index 5da7a75..530608a 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -4321,6 +4321,13 @@ public class StaticEndpointBuilders {
* Path parameter: channel (required)
* Channel of the Dynamic Router
*
+ * Path parameter: controlAction
+ * Control channel action: subscribe or unsubscribe
+ * There are 2 enums and the value can be one of: subscribe, unsubscribe
+ *
+ * Path parameter: subscribeChannel
+ * The channel to subscribe to
+ *
* @param path channel
* @return the dsl builder
*/
@@ -4342,6 +4349,13 @@ public class StaticEndpointBuilders {
* Path parameter: channel (required)
* Channel of the Dynamic Router
*
+ * Path parameter: controlAction
+ * Control channel action: subscribe or unsubscribe
+ * There are 2 enums and the value can be one of: subscribe, unsubscribe
+ *
+ * Path parameter: subscribeChannel
+ * The channel to subscribe to
+ *
* @param componentName to use a custom component name for the endpoint
* instead of the default name
* @param path channel
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
index 08f845a..31602ae 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
@@ -36,138 +36,24 @@ public interface DynamicRouterEndpointBuilderFactory {
/**
- * Builder for endpoint consumers for the Dynamic Router component.
- */
- public interface DynamicRouterEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedDynamicRouterEndpointConsumerBuilder advanced() {
- return (AdvancedDynamicRouterEndpointConsumerBuilder) this;
- }
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions occurred while the consumer is trying to
- * pickup incoming messages, or the likes, will now be processed as a
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default DynamicRouterEndpointConsumerBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions occurred while the consumer is trying to
- * pickup incoming messages, or the likes, will now be processed as a
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default DynamicRouterEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the Dynamic Router
component.
+ * Builder for endpoint for the Dynamic Router component.
*/
- public interface AdvancedDynamicRouterEndpointConsumerBuilder
+ public interface DynamicRouterEndpointBuilder
extends
- EndpointConsumerBuilder {
- default DynamicRouterEndpointConsumerBuilder basic() {
- return (DynamicRouterEndpointConsumerBuilder) this;
- }
- /**
- * To let the consumer use a custom ExceptionHandler. Notice if the
- * option bridgeErrorHandler is enabled then this option is not in use.
- * By default the consumer will deal with exceptions, that will be
- * logged at WARN or ERROR level and ignored.
- *
- * The option is a:
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedDynamicRouterEndpointConsumerBuilder exceptionHandler(
- org.apache.camel.spi.ExceptionHandler exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * To let the consumer use a custom ExceptionHandler. Notice if the
- * option bridgeErrorHandler is enabled then this option is not in use.
- * By default the consumer will deal with exceptions, that will be
- * logged at WARN or ERROR level and ignored.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedDynamicRouterEndpointConsumerBuilder exceptionHandler(
- String exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option is a:
- * <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exchangePattern the value to set
- * @return the dsl builder
- */
- default AdvancedDynamicRouterEndpointConsumerBuilder exchangePattern(
- org.apache.camel.ExchangePattern exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
+ EndpointProducerBuilder {
/**
- * Sets the exchange pattern when the consumer creates an exchange.
+ * Recipient mode: firstMatch or allMatch.
*
- * The option will be converted to a
- * <code>org.apache.camel.ExchangePattern</code> type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Group: consumer (advanced)
+ * Default: firstMatch
+ * Group: common
*
- * @param exchangePattern the value to set
+ * @param recipientMode the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointConsumerBuilder exchangePattern(
- String exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
+ default DynamicRouterEndpointBuilder recipientMode(String
recipientMode) {
+ doSetProperty("recipientMode", recipientMode);
return this;
}
/**
@@ -176,13 +62,12 @@ public interface DynamicRouterEndpointBuilderFactory {
* The option is a: <code>boolean</code> type.
*
* Default: false
- * Group: advanced
+ * Group: common
*
* @param synchronous the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointConsumerBuilder synchronous(
- boolean synchronous) {
+ default DynamicRouterEndpointBuilder synchronous(boolean synchronous) {
doSetProperty("synchronous", synchronous);
return this;
}
@@ -193,91 +78,46 @@ public interface DynamicRouterEndpointBuilderFactory {
* type.
*
* Default: false
- * Group: advanced
+ * Group: common
*
* @param synchronous the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointConsumerBuilder synchronous(
- String synchronous) {
+ default DynamicRouterEndpointBuilder synchronous(String synchronous) {
doSetProperty("synchronous", synchronous);
return this;
}
- }
-
- /**
- * Builder for endpoint producers for the Dynamic Router component.
- */
- public interface DynamicRouterEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedDynamicRouterEndpointProducerBuilder advanced() {
- return (AdvancedDynamicRouterEndpointProducerBuilder) this;
- }
- /**
- * Flag that determines if the producer should block while waiting for
a
- * consumer.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: producer
- *
- * @param block the value to set
- * @return the dsl builder
- */
- default DynamicRouterEndpointProducerBuilder block(boolean block) {
- doSetProperty("block", block);
- return this;
- }
- /**
- * Flag that determines if the producer should block while waiting for
a
- * consumer.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: producer
- *
- * @param block the value to set
- * @return the dsl builder
- */
- default DynamicRouterEndpointProducerBuilder block(String block) {
- doSetProperty("block", block);
- return this;
- }
/**
- * Flag to fail if there are no consumers.
+ * Flag to log a warning if no predicates match for an exchange.
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
- * Group: producer
+ * Default: false
+ * Group: common
*
- * @param failIfNoConsumers the value to set
+ * @param warnDroppedMessage the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder failIfNoConsumers(
- boolean failIfNoConsumers) {
- doSetProperty("failIfNoConsumers", failIfNoConsumers);
+ default DynamicRouterEndpointBuilder warnDroppedMessage(
+ boolean warnDroppedMessage) {
+ doSetProperty("warnDroppedMessage", warnDroppedMessage);
return this;
}
/**
- * Flag to fail if there are no consumers.
+ * Flag to log a warning if no predicates match for an exchange.
*
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
- * Group: producer
+ * Default: false
+ * Group: common
*
- * @param failIfNoConsumers the value to set
+ * @param warnDroppedMessage the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder failIfNoConsumers(
- String failIfNoConsumers) {
- doSetProperty("failIfNoConsumers", failIfNoConsumers);
+ default DynamicRouterEndpointBuilder warnDroppedMessage(
+ String warnDroppedMessage) {
+ doSetProperty("warnDroppedMessage", warnDroppedMessage);
return this;
}
/**
@@ -299,7 +139,7 @@ public interface DynamicRouterEndpointBuilderFactory {
* @param lazyStartProducer the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder lazyStartProducer(
+ default DynamicRouterEndpointBuilder lazyStartProducer(
boolean lazyStartProducer) {
doSetProperty("lazyStartProducer", lazyStartProducer);
return this;
@@ -324,175 +164,130 @@ public interface DynamicRouterEndpointBuilderFactory {
* @param lazyStartProducer the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder lazyStartProducer(
+ default DynamicRouterEndpointBuilder lazyStartProducer(
String lazyStartProducer) {
doSetProperty("lazyStartProducer", lazyStartProducer);
return this;
}
/**
- * The time limit, in milliseconds, if/when the producer blocks while
- * waiting for a consumer.
+ * The destination URI for exchanges that match.
*
- * The option is a: <code>long</code> type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Default: 30000
- * Group: producer
+ * Group: control
*
- * @param timeout the value to set
+ * @param destinationUri the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder timeout(long timeout) {
- doSetProperty("timeout", timeout);
+ default DynamicRouterEndpointBuilder destinationUri(
+ String destinationUri) {
+ doSetProperty("destinationUri", destinationUri);
return this;
}
/**
- * The time limit, in milliseconds, if/when the producer blocks while
- * waiting for a consumer.
+ * The subscription predicate language.
*
- * The option will be converted to a <code>long</code>
type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Default: 30000
- * Group: producer
+ * Default: simple
+ * Group: control
*
- * @param timeout the value to set
+ * @param expressionLanguage the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder timeout(String timeout) {
- doSetProperty("timeout", timeout);
+ default DynamicRouterEndpointBuilder expressionLanguage(
+ String expressionLanguage) {
+ doSetProperty("expressionLanguage", expressionLanguage);
return this;
}
/**
- * Flag to log a warning if no predicates match for an exchange.
+ * The subscription predicate.
*
- * The option is a: <code>boolean</code> type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Default: false
- * Group: producer
+ * Group: control
*
- * @param warnDroppedMessage the value to set
+ * @param predicate the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder warnDroppedMessage(
- boolean warnDroppedMessage) {
- doSetProperty("warnDroppedMessage", warnDroppedMessage);
+ default DynamicRouterEndpointBuilder predicate(String predicate) {
+ doSetProperty("predicate", predicate);
return this;
}
/**
- * Flag to log a warning if no predicates match for an exchange.
+ * A Predicate instance in the registry.
*
- * The option will be converted to a <code>boolean</code>
+ * The option is a: <code>org.apache.camel.Predicate</code>
* type.
*
- * Default: false
- * Group: producer
+ * Group: control
*
- * @param warnDroppedMessage the value to set
+ * @param predicateBean the value to set
* @return the dsl builder
*/
- default DynamicRouterEndpointProducerBuilder warnDroppedMessage(
- String warnDroppedMessage) {
- doSetProperty("warnDroppedMessage", warnDroppedMessage);
+ default DynamicRouterEndpointBuilder predicateBean(
+ org.apache.camel.Predicate predicateBean) {
+ doSetProperty("predicateBean", predicateBean);
return this;
}
- }
-
- /**
- * Advanced builder for endpoint producers for the Dynamic Router
component.
- */
- public interface AdvancedDynamicRouterEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default DynamicRouterEndpointProducerBuilder basic() {
- return (DynamicRouterEndpointProducerBuilder) this;
- }
/**
- * Flag to ensure synchronous processing.
+ * A Predicate instance in the registry.
*
- * The option is a: <code>boolean</code> type.
+ * The option will be converted to a
+ * <code>org.apache.camel.Predicate</code> type.
*
- * Default: false
- * Group: advanced
+ * Group: control
*
- * @param synchronous the value to set
+ * @param predicateBean the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointProducerBuilder synchronous(
- boolean synchronous) {
- doSetProperty("synchronous", synchronous);
+ default DynamicRouterEndpointBuilder predicateBean(String
predicateBean) {
+ doSetProperty("predicateBean", predicateBean);
return this;
}
/**
- * Flag to ensure synchronous processing.
+ * The subscription priority.
*
- * The option will be converted to a <code>boolean</code>
- * type.
+ * The option is a: <code>java.lang.Integer</code> type.
*
- * Default: false
- * Group: advanced
+ * Group: control
*
- * @param synchronous the value to set
+ * @param priority the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointProducerBuilder synchronous(
- String synchronous) {
- doSetProperty("synchronous", synchronous);
+ default DynamicRouterEndpointBuilder priority(Integer priority) {
+ doSetProperty("priority", priority);
return this;
}
- }
-
- /**
- * Builder for endpoint for the Dynamic Router component.
- */
- public interface DynamicRouterEndpointBuilder
- extends
- DynamicRouterEndpointConsumerBuilder,
- DynamicRouterEndpointProducerBuilder {
- default AdvancedDynamicRouterEndpointBuilder advanced() {
- return (AdvancedDynamicRouterEndpointBuilder) this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Dynamic Router component.
- */
- public interface AdvancedDynamicRouterEndpointBuilder
- extends
- AdvancedDynamicRouterEndpointConsumerBuilder,
- AdvancedDynamicRouterEndpointProducerBuilder {
- default DynamicRouterEndpointBuilder basic() {
- return (DynamicRouterEndpointBuilder) this;
- }
/**
- * Flag to ensure synchronous processing.
+ * The subscription priority.
*
- * The option is a: <code>boolean</code> type.
+ * The option will be converted to a
+ * <code>java.lang.Integer</code> type.
*
- * Default: false
- * Group: advanced
+ * Group: control
*
- * @param synchronous the value to set
+ * @param priority the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointBuilder synchronous(
- boolean synchronous) {
- doSetProperty("synchronous", synchronous);
+ default DynamicRouterEndpointBuilder priority(String priority) {
+ doSetProperty("priority", priority);
return this;
}
/**
- * Flag to ensure synchronous processing.
+ * The subscription ID; if unspecified, one will be assigned and
+ * returned.
*
- * The option will be converted to a <code>boolean</code>
- * type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Default: false
- * Group: advanced
+ * Group: control
*
- * @param synchronous the value to set
+ * @param subscriptionId the value to set
* @return the dsl builder
*/
- default AdvancedDynamicRouterEndpointBuilder synchronous(
- String synchronous) {
- doSetProperty("synchronous", synchronous);
+ default DynamicRouterEndpointBuilder subscriptionId(
+ String subscriptionId) {
+ doSetProperty("subscriptionId", subscriptionId);
return this;
}
}
@@ -512,6 +307,13 @@ public interface DynamicRouterEndpointBuilderFactory {
* Path parameter: channel (required)
* Channel of the Dynamic Router
*
+ * Path parameter: controlAction
+ * Control channel action: subscribe or unsubscribe
+ * There are 2 enums and the value can be one of: subscribe,
unsubscribe
+ *
+ * Path parameter: subscribeChannel
+ * The channel to subscribe to
+ *
* @param path channel
* @return the dsl builder
*/
@@ -532,6 +334,13 @@ public interface DynamicRouterEndpointBuilderFactory {
* Path parameter: channel (required)
* Channel of the Dynamic Router
*
+ * Path parameter: controlAction
+ * Control channel action: subscribe or unsubscribe
+ * There are 2 enums and the value can be one of: subscribe,
unsubscribe
+ *
+ * Path parameter: subscribeChannel
+ * The channel to subscribe to
+ *
* @param componentName to use a custom component name for the endpoint
* instead of the default name
* @param path channel
@@ -546,7 +355,7 @@ public interface DynamicRouterEndpointBuilderFactory {
static DynamicRouterEndpointBuilder endpointBuilder(
String componentName,
String path) {
- class DynamicRouterEndpointBuilderImpl extends AbstractEndpointBuilder
implements DynamicRouterEndpointBuilder, AdvancedDynamicRouterEndpointBuilder {
+ class DynamicRouterEndpointBuilderImpl extends AbstractEndpointBuilder
implements DynamicRouterEndpointBuilder {
public DynamicRouterEndpointBuilderImpl(String path) {
super(componentName, path);
}
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/EndpointConsumerDeserializersResolver.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/EndpointConsumerDeserializersResolver.java
index 9d6535a..f73edd3 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/EndpointConsumerDeserializersResolver.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/EndpointConsumerDeserializersResolver.java
@@ -69,7 +69,6 @@ public final class EndpointConsumerDeserializersResolver
implements YamlDeserial
case "disruptor-vm":
case "docker":
case "dropbox":
- case "dynamic-router":
case "ehcache":
case "elsql":
case "etcd-stats":
