This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 894163516d232327304497aeeef9cf5fa57d2f5b
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Mar 2 13:35:51 2021 +0100
CAMEL-16171 - Add uri-endpoint-override options to all AWS2 components -
AWS2-MQ component
---
.../camel/catalog/docs/aws2-mq-component.adoc | 8 +++-
.../component/aws2/mq/MQ2ComponentConfigurer.java | 12 ++++++
.../component/aws2/mq/MQ2EndpointConfigurer.java | 12 ++++++
.../component/aws2/mq/MQ2EndpointUriFactory.java | 14 ++++---
.../apache/camel/component/aws2/mq/aws2-mq.json | 4 ++
.../src/main/docs/aws2-mq-component.adoc | 8 +++-
.../dsl/Aws2MqComponentBuilderFactory.java | 34 +++++++++++++++
.../endpoint/dsl/MQ2EndpointBuilderFactory.java | 49 ++++++++++++++++++++++
.../modules/ROOT/pages/aws2-mq-component.adoc | 8 +++-
9 files changed, 137 insertions(+), 12 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
index 6c8fba6..a242039 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-mq-component.adoc
@@ -42,7 +42,7 @@ You can append query options to the URI in the following
format,
// component options: START
-The AWS 2 MQ component supports 13 options, which are listed below.
+The AWS 2 MQ component supports 15 options, which are listed below.
@@ -53,12 +53,14 @@ The AWS 2 MQ component supports 13 options, which are
listed below.
| *configuration* (producer) | Component configuration | | MQ2Configuration
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | *Required* The operation to perform. It can be
listBrokers,createBroker,deleteBroker. There are 6 enums and the value can be
one of: listBrokers, createBroker, deleteBroker, rebootBroker, updateBroker,
describeBroker | | MQ2Operations
+| *overrideEndpoint* (producer) | Set the need for overidding the endpoint.
This option needs to be used in combination with uriEndpointOverride option |
false | boolean
| *pojoRequest* (producer) | If we want to use a POJO request as body or not |
false | boolean
| *proxyHost* (producer) | To define a proxy host when instantiating the MQ
client | | String
| *proxyPort* (producer) | To define a proxy port when instantiating the MQ
client | | Integer
| *proxyProtocol* (producer) | To define a proxy protocol when instantiating
the MQ client. There are 2 enums and the value can be one of: HTTP, HTTPS |
HTTPS | Protocol
| *region* (producer) | The region in which MQ client needs to work. When
using this parameter, the configuration will expect the lowercase name of the
region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | | String
| *trustAllCertificates* (producer) | If we want to trust all certificates in
case of overriding the endpoint | false | boolean
+| *uriEndpointOverride* (producer) | Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option | | String
| *autowiredEnabled* (advanced) | 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 then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
| *accessKey* (security) | Amazon AWS Access Key | | String
| *secretKey* (security) | Amazon AWS Secret Key | | String
@@ -87,7 +89,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (11 parameters):
+=== Query Parameters (13 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -96,12 +98,14 @@ with the following path and query parameters:
| *amazonMqClient* (producer) | *Autowired* To use a existing configured
AmazonMQClient as client | | MqClient
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | *Required* The operation to perform. It can be
listBrokers,createBroker,deleteBroker. There are 6 enums and the value can be
one of: listBrokers, createBroker, deleteBroker, rebootBroker, updateBroker,
describeBroker | | MQ2Operations
+| *overrideEndpoint* (producer) | Set the need for overidding the endpoint.
This option needs to be used in combination with uriEndpointOverride option |
false | boolean
| *pojoRequest* (producer) | If we want to use a POJO request as body or not |
false | boolean
| *proxyHost* (producer) | To define a proxy host when instantiating the MQ
client | | String
| *proxyPort* (producer) | To define a proxy port when instantiating the MQ
client | | Integer
| *proxyProtocol* (producer) | To define a proxy protocol when instantiating
the MQ client. There are 2 enums and the value can be one of: HTTP, HTTPS |
HTTPS | Protocol
| *region* (producer) | The region in which MQ client needs to work. When
using this parameter, the configuration will expect the lowercase name of the
region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | | String
| *trustAllCertificates* (producer) | If we want to trust all certificates in
case of overriding the endpoint | false | boolean
+| *uriEndpointOverride* (producer) | Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option | | String
| *accessKey* (security) | Amazon AWS Access Key | | String
| *secretKey* (security) | Amazon AWS Secret Key | | String
|===
diff --git
a/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2ComponentConfigurer.java
b/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2ComponentConfigurer.java
index 3c15462..8ffeb7c 100644
---
a/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2ComponentConfigurer.java
+++
b/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2ComponentConfigurer.java
@@ -38,6 +38,8 @@ public class MQ2ComponentConfigurer extends
PropertyConfigurerSupport implements
case "lazystartproducer":
case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
case "operation":
getOrCreateConfiguration(target).setOperation(property(camelContext,
org.apache.camel.component.aws2.mq.MQ2Operations.class, value)); return true;
+ case "overrideendpoint":
+ case "overrideEndpoint":
getOrCreateConfiguration(target).setOverrideEndpoint(property(camelContext,
boolean.class, value)); return true;
case "pojorequest":
case "pojoRequest":
getOrCreateConfiguration(target).setPojoRequest(property(camelContext,
boolean.class, value)); return true;
case "proxyhost":
@@ -51,6 +53,8 @@ public class MQ2ComponentConfigurer extends
PropertyConfigurerSupport implements
case "secretKey":
getOrCreateConfiguration(target).setSecretKey(property(camelContext,
java.lang.String.class, value)); return true;
case "trustallcertificates":
case "trustAllCertificates":
getOrCreateConfiguration(target).setTrustAllCertificates(property(camelContext,
boolean.class, value)); return true;
+ case "uriendpointoverride":
+ case "uriEndpointOverride":
getOrCreateConfiguration(target).setUriEndpointOverride(property(camelContext,
java.lang.String.class, value)); return true;
default: return false;
}
}
@@ -73,6 +77,8 @@ public class MQ2ComponentConfigurer extends
PropertyConfigurerSupport implements
case "lazystartproducer":
case "lazyStartProducer": return boolean.class;
case "operation": return
org.apache.camel.component.aws2.mq.MQ2Operations.class;
+ case "overrideendpoint":
+ case "overrideEndpoint": return boolean.class;
case "pojorequest":
case "pojoRequest": return boolean.class;
case "proxyhost":
@@ -86,6 +92,8 @@ public class MQ2ComponentConfigurer extends
PropertyConfigurerSupport implements
case "secretKey": return java.lang.String.class;
case "trustallcertificates":
case "trustAllCertificates": return boolean.class;
+ case "uriendpointoverride":
+ case "uriEndpointOverride": return java.lang.String.class;
default: return null;
}
}
@@ -104,6 +112,8 @@ public class MQ2ComponentConfigurer extends
PropertyConfigurerSupport implements
case "lazystartproducer":
case "lazyStartProducer": return target.isLazyStartProducer();
case "operation": return
getOrCreateConfiguration(target).getOperation();
+ case "overrideendpoint":
+ case "overrideEndpoint": return
getOrCreateConfiguration(target).isOverrideEndpoint();
case "pojorequest":
case "pojoRequest": return
getOrCreateConfiguration(target).isPojoRequest();
case "proxyhost":
@@ -117,6 +127,8 @@ public class MQ2ComponentConfigurer extends
PropertyConfigurerSupport implements
case "secretKey": return
getOrCreateConfiguration(target).getSecretKey();
case "trustallcertificates":
case "trustAllCertificates": return
getOrCreateConfiguration(target).isTrustAllCertificates();
+ case "uriendpointoverride":
+ case "uriEndpointOverride": return
getOrCreateConfiguration(target).getUriEndpointOverride();
default: return null;
}
}
diff --git
a/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointConfigurer.java
b/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointConfigurer.java
index 9f16bb1..e8f33fb 100644
---
a/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointConfigurer.java
+++
b/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointConfigurer.java
@@ -28,6 +28,8 @@ public class MQ2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "lazystartproducer":
case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
case "operation":
target.getConfiguration().setOperation(property(camelContext,
org.apache.camel.component.aws2.mq.MQ2Operations.class, value)); return true;
+ case "overrideendpoint":
+ case "overrideEndpoint":
target.getConfiguration().setOverrideEndpoint(property(camelContext,
boolean.class, value)); return true;
case "pojorequest":
case "pojoRequest":
target.getConfiguration().setPojoRequest(property(camelContext, boolean.class,
value)); return true;
case "proxyhost":
@@ -41,6 +43,8 @@ public class MQ2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "secretKey":
target.getConfiguration().setSecretKey(property(camelContext,
java.lang.String.class, value)); return true;
case "trustallcertificates":
case "trustAllCertificates":
target.getConfiguration().setTrustAllCertificates(property(camelContext,
boolean.class, value)); return true;
+ case "uriendpointoverride":
+ case "uriEndpointOverride":
target.getConfiguration().setUriEndpointOverride(property(camelContext,
java.lang.String.class, value)); return true;
default: return false;
}
}
@@ -60,6 +64,8 @@ public class MQ2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "lazystartproducer":
case "lazyStartProducer": return boolean.class;
case "operation": return
org.apache.camel.component.aws2.mq.MQ2Operations.class;
+ case "overrideendpoint":
+ case "overrideEndpoint": return boolean.class;
case "pojorequest":
case "pojoRequest": return boolean.class;
case "proxyhost":
@@ -73,6 +79,8 @@ public class MQ2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "secretKey": return java.lang.String.class;
case "trustallcertificates":
case "trustAllCertificates": return boolean.class;
+ case "uriendpointoverride":
+ case "uriEndpointOverride": return java.lang.String.class;
default: return null;
}
}
@@ -88,6 +96,8 @@ public class MQ2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "lazystartproducer":
case "lazyStartProducer": return target.isLazyStartProducer();
case "operation": return target.getConfiguration().getOperation();
+ case "overrideendpoint":
+ case "overrideEndpoint": return
target.getConfiguration().isOverrideEndpoint();
case "pojorequest":
case "pojoRequest": return target.getConfiguration().isPojoRequest();
case "proxyhost":
@@ -101,6 +111,8 @@ public class MQ2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "secretKey": return target.getConfiguration().getSecretKey();
case "trustallcertificates":
case "trustAllCertificates": return
target.getConfiguration().isTrustAllCertificates();
+ case "uriendpointoverride":
+ case "uriEndpointOverride": return
target.getConfiguration().getUriEndpointOverride();
default: return null;
}
}
diff --git
a/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointUriFactory.java
b/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointUriFactory.java
index 11b6792..56b9549 100644
---
a/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointUriFactory.java
+++
b/components/camel-aws2-mq/src/generated/java/org/apache/camel/component/aws2/mq/MQ2EndpointUriFactory.java
@@ -20,19 +20,21 @@ public class MQ2EndpointUriFactory extends
org.apache.camel.support.component.En
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(12);
+ Set<String> props = new HashSet<>(14);
props.add("amazonMqClient");
- props.add("proxyPort");
- props.add("lazyStartProducer");
props.add("proxyProtocol");
props.add("secretKey");
- props.add("accessKey");
+ props.add("uriEndpointOverride");
props.add("label");
- props.add("region");
- props.add("operation");
props.add("pojoRequest");
props.add("proxyHost");
props.add("trustAllCertificates");
+ props.add("proxyPort");
+ props.add("lazyStartProducer");
+ props.add("accessKey");
+ props.add("overrideEndpoint");
+ props.add("region");
+ props.add("operation");
PROPERTY_NAMES = Collections.unmodifiableSet(props);
Set<String> secretProps = new HashSet<>(2);
secretProps.add("secretKey");
diff --git
a/components/camel-aws2-mq/src/generated/resources/org/apache/camel/component/aws2/mq/aws2-mq.json
b/components/camel-aws2-mq/src/generated/resources/org/apache/camel/component/aws2/mq/aws2-mq.json
index f8d3018..bada881 100644
---
a/components/camel-aws2-mq/src/generated/resources/org/apache/camel/component/aws2/mq/aws2-mq.json
+++
b/components/camel-aws2-mq/src/generated/resources/org/apache/camel/component/aws2/mq/aws2-mq.json
@@ -26,12 +26,14 @@
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"deprecated": false, "autowired": false, "secret": false, "description":
"Component configuration" },
"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 [...]
"operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.aws2.mq.MQ2Operations", "enum": [ "listBrokers",
"createBroker", "deleteBroker", "rebootBroker", "updateBroker",
"describeBroker" ], "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField": "c
[...]
+ "overrideEndpoint": { "kind": "property", "displayName": "Override
Endpoint", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Set the need for overidding the endpoint. This
option needs to be used in combination with uriEndpoint [...]
"pojoRequest": { "kind": "property", "displayName": "Pojo Request",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "If we want to use a POJO request as body or
not" },
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the MQ client" },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group":
"producer", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the MQ client" },
"proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"HTTPS", "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "To define a proxy protocol when instantiating
the [...]
"region": { "kind": "property", "displayName": "Region", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "The region in which MQ
client needs to work. When using this parameter, the configuration will expect
the lowercase name of the region (fo [...]
"trustAllCertificates": { "kind": "property", "displayName": "Trust All
Certificates", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "If we want to trust all certificates in case
of overriding the endpoint" },
+ "uriEndpointOverride": { "kind": "property", "displayName": "Uri Endpoint
Override", "group": "producer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Set the overriding uri endpoint. This option
needs to be used in combination with overrideEndpoint option" },
"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 [...]
"accessKey": { "kind": "property", "displayName": "Access Key", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Amazon AWS Access Key" },
"secretKey": { "kind": "property", "displayName": "Secret Key", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Amazon AWS Secret Key" }
@@ -41,12 +43,14 @@
"amazonMqClient": { "kind": "parameter", "displayName": "Amazon Mq
Client", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.mq.MqClient", "deprecated": false,
"deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "To use a existing
configured AmazonMQClient as client" },
"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 [...]
"operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.aws2.mq.MQ2Operations", "enum": [ "listBrokers",
"createBroker", "deleteBroker", "rebootBroker", "updateBroker",
"describeBroker" ], "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField": "
[...]
+ "overrideEndpoint": { "kind": "parameter", "displayName": "Override
Endpoint", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Set the need for overidding the endpoint. This
option needs to be used in combination with uriEndpoin [...]
"pojoRequest": { "kind": "parameter", "displayName": "Pojo Request",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "If we want to use a POJO request as body or
not" },
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the MQ client" },
"proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group":
"producer", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the MQ client" },
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"HTTPS", "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "To define a proxy protocol when instantiating
th [...]
"region": { "kind": "parameter", "displayName": "Region", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.mq.MQ2Configuration",
"configurationField": "configuration", "description": "The region in which MQ
client needs to work. When using this parameter, the configuration will expect
the lowercase name of the region (f [...]
"trustAllCertificates": { "kind": "parameter", "displayName": "Trust All
Certificates", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "If we want to trust all certificates in case
of overriding the endpoint" },
+ "uriEndpointOverride": { "kind": "parameter", "displayName": "Uri Endpoint
Override", "group": "producer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Set the overriding uri endpoint. This option
needs to be used in combination with overrideEndpoint option" },
"accessKey": { "kind": "parameter", "displayName": "Access Key", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Amazon AWS Access Key" },
"secretKey": { "kind": "parameter", "displayName": "Secret Key", "group":
"security", "label": "security", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": true, "configurationClass":
"org.apache.camel.component.aws2.mq.MQ2Configuration", "configurationField":
"configuration", "description": "Amazon AWS Secret Key" }
}
diff --git a/components/camel-aws2-mq/src/main/docs/aws2-mq-component.adoc
b/components/camel-aws2-mq/src/main/docs/aws2-mq-component.adoc
index 6c8fba6..a242039 100644
--- a/components/camel-aws2-mq/src/main/docs/aws2-mq-component.adoc
+++ b/components/camel-aws2-mq/src/main/docs/aws2-mq-component.adoc
@@ -42,7 +42,7 @@ You can append query options to the URI in the following
format,
// component options: START
-The AWS 2 MQ component supports 13 options, which are listed below.
+The AWS 2 MQ component supports 15 options, which are listed below.
@@ -53,12 +53,14 @@ The AWS 2 MQ component supports 13 options, which are
listed below.
| *configuration* (producer) | Component configuration | | MQ2Configuration
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | *Required* The operation to perform. It can be
listBrokers,createBroker,deleteBroker. There are 6 enums and the value can be
one of: listBrokers, createBroker, deleteBroker, rebootBroker, updateBroker,
describeBroker | | MQ2Operations
+| *overrideEndpoint* (producer) | Set the need for overidding the endpoint.
This option needs to be used in combination with uriEndpointOverride option |
false | boolean
| *pojoRequest* (producer) | If we want to use a POJO request as body or not |
false | boolean
| *proxyHost* (producer) | To define a proxy host when instantiating the MQ
client | | String
| *proxyPort* (producer) | To define a proxy port when instantiating the MQ
client | | Integer
| *proxyProtocol* (producer) | To define a proxy protocol when instantiating
the MQ client. There are 2 enums and the value can be one of: HTTP, HTTPS |
HTTPS | Protocol
| *region* (producer) | The region in which MQ client needs to work. When
using this parameter, the configuration will expect the lowercase name of the
region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | | String
| *trustAllCertificates* (producer) | If we want to trust all certificates in
case of overriding the endpoint | false | boolean
+| *uriEndpointOverride* (producer) | Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option | | String
| *autowiredEnabled* (advanced) | 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 then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
| *accessKey* (security) | Amazon AWS Access Key | | String
| *secretKey* (security) | Amazon AWS Secret Key | | String
@@ -87,7 +89,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (11 parameters):
+=== Query Parameters (13 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -96,12 +98,14 @@ with the following path and query parameters:
| *amazonMqClient* (producer) | *Autowired* To use a existing configured
AmazonMQClient as client | | MqClient
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | *Required* The operation to perform. It can be
listBrokers,createBroker,deleteBroker. There are 6 enums and the value can be
one of: listBrokers, createBroker, deleteBroker, rebootBroker, updateBroker,
describeBroker | | MQ2Operations
+| *overrideEndpoint* (producer) | Set the need for overidding the endpoint.
This option needs to be used in combination with uriEndpointOverride option |
false | boolean
| *pojoRequest* (producer) | If we want to use a POJO request as body or not |
false | boolean
| *proxyHost* (producer) | To define a proxy host when instantiating the MQ
client | | String
| *proxyPort* (producer) | To define a proxy port when instantiating the MQ
client | | Integer
| *proxyProtocol* (producer) | To define a proxy protocol when instantiating
the MQ client. There are 2 enums and the value can be one of: HTTP, HTTPS |
HTTPS | Protocol
| *region* (producer) | The region in which MQ client needs to work. When
using this parameter, the configuration will expect the lowercase name of the
region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | | String
| *trustAllCertificates* (producer) | If we want to trust all certificates in
case of overriding the endpoint | false | boolean
+| *uriEndpointOverride* (producer) | Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option | | String
| *accessKey* (security) | Amazon AWS Access Key | | String
| *secretKey* (security) | Amazon AWS Secret Key | | String
|===
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2MqComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2MqComponentBuilderFactory.java
index 5fe7850..3bba48b 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2MqComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2MqComponentBuilderFactory.java
@@ -123,6 +123,22 @@ public interface Aws2MqComponentBuilderFactory {
return this;
}
/**
+ * Set the need for overidding the endpoint. This option needs to be
+ * used in combination with uriEndpointOverride option.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param overrideEndpoint the value to set
+ * @return the dsl builder
+ */
+ default Aws2MqComponentBuilder overrideEndpoint(boolean
overrideEndpoint) {
+ doSetProperty("overrideEndpoint", overrideEndpoint);
+ return this;
+ }
+ /**
* If we want to use a POJO request as body or not.
*
* The option is a: <code>boolean</code> type.
@@ -217,6 +233,22 @@ public interface Aws2MqComponentBuilderFactory {
return this;
}
/**
+ * Set the overriding uri endpoint. This option needs to be used in
+ * combination with overrideEndpoint option.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param uriEndpointOverride the value to set
+ * @return the dsl builder
+ */
+ default Aws2MqComponentBuilder uriEndpointOverride(
+ java.lang.String uriEndpointOverride) {
+ doSetProperty("uriEndpointOverride", uriEndpointOverride);
+ return this;
+ }
+ /**
* 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,
@@ -292,12 +324,14 @@ public interface Aws2MqComponentBuilderFactory {
case "configuration": ((MQ2Component)
component).setConfiguration((org.apache.camel.component.aws2.mq.MQ2Configuration)
value); return true;
case "lazyStartProducer": ((MQ2Component)
component).setLazyStartProducer((boolean) value); return true;
case "operation": getOrCreateConfiguration((MQ2Component)
component).setOperation((org.apache.camel.component.aws2.mq.MQ2Operations)
value); return true;
+ case "overrideEndpoint": getOrCreateConfiguration((MQ2Component)
component).setOverrideEndpoint((boolean) value); return true;
case "pojoRequest": getOrCreateConfiguration((MQ2Component)
component).setPojoRequest((boolean) value); return true;
case "proxyHost": getOrCreateConfiguration((MQ2Component)
component).setProxyHost((java.lang.String) value); return true;
case "proxyPort": getOrCreateConfiguration((MQ2Component)
component).setProxyPort((java.lang.Integer) value); return true;
case "proxyProtocol": getOrCreateConfiguration((MQ2Component)
component).setProxyProtocol((software.amazon.awssdk.core.Protocol) value);
return true;
case "region": getOrCreateConfiguration((MQ2Component)
component).setRegion((java.lang.String) value); return true;
case "trustAllCertificates":
getOrCreateConfiguration((MQ2Component)
component).setTrustAllCertificates((boolean) value); return true;
+ case "uriEndpointOverride":
getOrCreateConfiguration((MQ2Component)
component).setUriEndpointOverride((java.lang.String) value); return true;
case "autowiredEnabled": ((MQ2Component)
component).setAutowiredEnabled((boolean) value); return true;
case "accessKey": getOrCreateConfiguration((MQ2Component)
component).setAccessKey((java.lang.String) value); return true;
case "secretKey": getOrCreateConfiguration((MQ2Component)
component).setSecretKey((java.lang.String) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MQ2EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MQ2EndpointBuilderFactory.java
index 8d2ba9f..254a135 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MQ2EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/MQ2EndpointBuilderFactory.java
@@ -148,6 +148,39 @@ public interface MQ2EndpointBuilderFactory {
return this;
}
/**
+ * Set the need for overidding the endpoint. This option needs to be
+ * used in combination with uriEndpointOverride option.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param overrideEndpoint the value to set
+ * @return the dsl builder
+ */
+ default MQ2EndpointBuilder overrideEndpoint(boolean overrideEndpoint) {
+ doSetProperty("overrideEndpoint", overrideEndpoint);
+ return this;
+ }
+ /**
+ * Set the need for overidding the endpoint. This option needs to be
+ * used in combination with uriEndpointOverride option.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param overrideEndpoint the value to set
+ * @return the dsl builder
+ */
+ default MQ2EndpointBuilder overrideEndpoint(String overrideEndpoint) {
+ doSetProperty("overrideEndpoint", overrideEndpoint);
+ return this;
+ }
+ /**
* If we want to use a POJO request as body or not.
*
* The option is a: <code>boolean</code> type.
@@ -306,6 +339,22 @@ public interface MQ2EndpointBuilderFactory {
return this;
}
/**
+ * Set the overriding uri endpoint. This option needs to be used in
+ * combination with overrideEndpoint option.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: producer
+ *
+ * @param uriEndpointOverride the value to set
+ * @return the dsl builder
+ */
+ default MQ2EndpointBuilder uriEndpointOverride(
+ String uriEndpointOverride) {
+ doSetProperty("uriEndpointOverride", uriEndpointOverride);
+ return this;
+ }
+ /**
* Amazon AWS Access Key.
*
* The option is a: <code>java.lang.String</code> type.
diff --git a/docs/components/modules/ROOT/pages/aws2-mq-component.adoc
b/docs/components/modules/ROOT/pages/aws2-mq-component.adoc
index 4c199e4..cbad519 100644
--- a/docs/components/modules/ROOT/pages/aws2-mq-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-mq-component.adoc
@@ -44,7 +44,7 @@ You can append query options to the URI in the following
format,
// component options: START
-The AWS 2 MQ component supports 13 options, which are listed below.
+The AWS 2 MQ component supports 15 options, which are listed below.
@@ -55,12 +55,14 @@ The AWS 2 MQ component supports 13 options, which are
listed below.
| *configuration* (producer) | Component configuration | | MQ2Configuration
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | *Required* The operation to perform. It can be
listBrokers,createBroker,deleteBroker. There are 6 enums and the value can be
one of: listBrokers, createBroker, deleteBroker, rebootBroker, updateBroker,
describeBroker | | MQ2Operations
+| *overrideEndpoint* (producer) | Set the need for overidding the endpoint.
This option needs to be used in combination with uriEndpointOverride option |
false | boolean
| *pojoRequest* (producer) | If we want to use a POJO request as body or not |
false | boolean
| *proxyHost* (producer) | To define a proxy host when instantiating the MQ
client | | String
| *proxyPort* (producer) | To define a proxy port when instantiating the MQ
client | | Integer
| *proxyProtocol* (producer) | To define a proxy protocol when instantiating
the MQ client. There are 2 enums and the value can be one of: HTTP, HTTPS |
HTTPS | Protocol
| *region* (producer) | The region in which MQ client needs to work. When
using this parameter, the configuration will expect the lowercase name of the
region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | | String
| *trustAllCertificates* (producer) | If we want to trust all certificates in
case of overriding the endpoint | false | boolean
+| *uriEndpointOverride* (producer) | Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option | | String
| *autowiredEnabled* (advanced) | 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 then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
| *accessKey* (security) | Amazon AWS Access Key | | String
| *secretKey* (security) | Amazon AWS Secret Key | | String
@@ -89,7 +91,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (11 parameters):
+=== Query Parameters (13 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -98,12 +100,14 @@ with the following path and query parameters:
| *amazonMqClient* (producer) | *Autowired* To use a existing configured
AmazonMQClient as client | | MqClient
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | *Required* The operation to perform. It can be
listBrokers,createBroker,deleteBroker. There are 6 enums and the value can be
one of: listBrokers, createBroker, deleteBroker, rebootBroker, updateBroker,
describeBroker | | MQ2Operations
+| *overrideEndpoint* (producer) | Set the need for overidding the endpoint.
This option needs to be used in combination with uriEndpointOverride option |
false | boolean
| *pojoRequest* (producer) | If we want to use a POJO request as body or not |
false | boolean
| *proxyHost* (producer) | To define a proxy host when instantiating the MQ
client | | String
| *proxyPort* (producer) | To define a proxy port when instantiating the MQ
client | | Integer
| *proxyProtocol* (producer) | To define a proxy protocol when instantiating
the MQ client. There are 2 enums and the value can be one of: HTTP, HTTPS |
HTTPS | Protocol
| *region* (producer) | The region in which MQ client needs to work. When
using this parameter, the configuration will expect the lowercase name of the
region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | | String
| *trustAllCertificates* (producer) | If we want to trust all certificates in
case of overriding the endpoint | false | boolean
+| *uriEndpointOverride* (producer) | Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option | | String
| *accessKey* (security) | Amazon AWS Access Key | | String
| *secretKey* (security) | Amazon AWS Secret Key | | String
|===
