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 674fde3 Regen
674fde3 is described below
commit 674fde3270b696038bc2bb23bc63dcdff75865a7
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jul 23 21:37:42 2021 +0200
Regen
---
.../huaweicloud/obs/OBSEndpointConfigurer.java | 138 +++
.../huaweicloud/obs/OBSEndpointUriFactory.java | 38 +-
.../component/huaweicloud/obs/hwcloud-obs.json | 44 +-
.../endpoint/dsl/OBSEndpointBuilderFactory.java | 1290 +++++++++++++++-----
.../modules/ROOT/pages/hwcloud-obs-component.adoc | 44 +-
5 files changed, 1239 insertions(+), 315 deletions(-)
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
index 6006444..23ed657 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointConfigurer.java
@@ -23,21 +23,47 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
switch (ignoreCase ? name.toLowerCase() : name) {
case "authenticationkey":
case "authenticationKey":
target.setAuthenticationKey(property(camelContext, java.lang.String.class,
value)); return true;
+ case "backofferrorthreshold":
+ case "backoffErrorThreshold":
target.setBackoffErrorThreshold(property(camelContext, int.class, value));
return true;
+ case "backoffidlethreshold":
+ case "backoffIdleThreshold":
target.setBackoffIdleThreshold(property(camelContext, int.class, value));
return true;
+ case "backoffmultiplier":
+ case "backoffMultiplier":
target.setBackoffMultiplier(property(camelContext, int.class, value)); return
true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
case "bucketlocation":
case "bucketLocation": target.setBucketLocation(property(camelContext,
java.lang.String.class, value)); return true;
case "bucketname":
case "bucketName": target.setBucketName(property(camelContext,
java.lang.String.class, value)); return true;
+ case "delay": target.setDelay(property(camelContext, long.class,
value)); return true;
+ case "deleteafterread":
+ case "deleteAfterRead":
target.setDeleteAfterRead(property(camelContext, boolean.class, value)); return
true;
+ case "delimiter": target.setDelimiter(property(camelContext,
java.lang.String.class, value)); return true;
+ case "destinationbucket":
+ case "destinationBucket":
target.setDestinationBucket(property(camelContext, java.lang.String.class,
value)); return true;
case "endpoint": target.setEndpoint(property(camelContext,
java.lang.String.class, value)); return true;
case "exceptionhandler":
case "exceptionHandler":
target.setExceptionHandler(property(camelContext,
org.apache.camel.spi.ExceptionHandler.class, value)); return true;
case "exchangepattern":
case "exchangePattern":
target.setExchangePattern(property(camelContext,
org.apache.camel.ExchangePattern.class, value)); return true;
+ case "filename":
+ case "fileName": target.setFileName(property(camelContext,
java.lang.String.class, value)); return true;
+ case "greedy": target.setGreedy(property(camelContext, boolean.class,
value)); return true;
case "ignoresslverification":
case "ignoreSslVerification":
target.setIgnoreSslVerification(property(camelContext, boolean.class, value));
return true;
+ case "includefolders":
+ case "includeFolders": target.setIncludeFolders(property(camelContext,
boolean.class, value)); return true;
+ case "initialdelay":
+ case "initialDelay": target.setInitialDelay(property(camelContext,
long.class, value)); return true;
case "lazystartproducer":
case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
+ case "maxmessagesperpoll":
+ case "maxMessagesPerPoll":
target.setMaxMessagesPerPoll(property(camelContext, int.class, value)); return
true;
+ case "moveafterread":
+ case "moveAfterRead": target.setMoveAfterRead(property(camelContext,
boolean.class, value)); return true;
+ case "pollstrategy":
+ case "pollStrategy": target.setPollStrategy(property(camelContext,
org.apache.camel.spi.PollingConsumerPollStrategy.class, value)); return true;
+ case "prefix": target.setPrefix(property(camelContext,
java.lang.String.class, value)); return true;
case "proxyhost":
case "proxyHost": target.setProxyHost(property(camelContext,
java.lang.String.class, value)); return true;
case "proxypassword":
@@ -47,10 +73,27 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
case "proxyuser":
case "proxyUser": target.setProxyUser(property(camelContext,
java.lang.String.class, value)); return true;
case "region": target.setRegion(property(camelContext,
java.lang.String.class, value)); return true;
+ case "repeatcount":
+ case "repeatCount": target.setRepeatCount(property(camelContext,
long.class, value)); return true;
+ case "runlogginglevel":
+ case "runLoggingLevel":
target.setRunLoggingLevel(property(camelContext,
org.apache.camel.LoggingLevel.class, value)); return true;
+ case "scheduledexecutorservice":
+ case "scheduledExecutorService":
target.setScheduledExecutorService(property(camelContext,
java.util.concurrent.ScheduledExecutorService.class, value)); return true;
+ case "scheduler": target.setScheduler(property(camelContext,
java.lang.Object.class, value)); return true;
+ case "schedulerproperties":
+ case "schedulerProperties":
target.setSchedulerProperties(property(camelContext, java.util.Map.class,
value)); return true;
case "secretkey":
case "secretKey": target.setSecretKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "sendemptymessagewhenidle":
+ case "sendEmptyMessageWhenIdle":
target.setSendEmptyMessageWhenIdle(property(camelContext, boolean.class,
value)); return true;
case "servicekeys":
case "serviceKeys": target.setServiceKeys(property(camelContext,
org.apache.camel.component.huaweicloud.obs.models.ServiceKeys.class, value));
return true;
+ case "startscheduler":
+ case "startScheduler": target.setStartScheduler(property(camelContext,
boolean.class, value)); return true;
+ case "timeunit":
+ case "timeUnit": target.setTimeUnit(property(camelContext,
java.util.concurrent.TimeUnit.class, value)); return true;
+ case "usefixeddelay":
+ case "useFixedDelay": target.setUseFixedDelay(property(camelContext,
boolean.class, value)); return true;
default: return false;
}
}
@@ -60,21 +103,47 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
switch (ignoreCase ? name.toLowerCase() : name) {
case "authenticationkey":
case "authenticationKey": return java.lang.String.class;
+ case "backofferrorthreshold":
+ case "backoffErrorThreshold": return int.class;
+ case "backoffidlethreshold":
+ case "backoffIdleThreshold": return int.class;
+ case "backoffmultiplier":
+ case "backoffMultiplier": return int.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
case "bucketlocation":
case "bucketLocation": return java.lang.String.class;
case "bucketname":
case "bucketName": return java.lang.String.class;
+ case "delay": return long.class;
+ case "deleteafterread":
+ case "deleteAfterRead": return boolean.class;
+ case "delimiter": return java.lang.String.class;
+ case "destinationbucket":
+ case "destinationBucket": return java.lang.String.class;
case "endpoint": return java.lang.String.class;
case "exceptionhandler":
case "exceptionHandler": return
org.apache.camel.spi.ExceptionHandler.class;
case "exchangepattern":
case "exchangePattern": return org.apache.camel.ExchangePattern.class;
+ case "filename":
+ case "fileName": return java.lang.String.class;
+ case "greedy": return boolean.class;
case "ignoresslverification":
case "ignoreSslVerification": return boolean.class;
+ case "includefolders":
+ case "includeFolders": return boolean.class;
+ case "initialdelay":
+ case "initialDelay": return long.class;
case "lazystartproducer":
case "lazyStartProducer": return boolean.class;
+ case "maxmessagesperpoll":
+ case "maxMessagesPerPoll": return int.class;
+ case "moveafterread":
+ case "moveAfterRead": return boolean.class;
+ case "pollstrategy":
+ case "pollStrategy": return
org.apache.camel.spi.PollingConsumerPollStrategy.class;
+ case "prefix": return java.lang.String.class;
case "proxyhost":
case "proxyHost": return java.lang.String.class;
case "proxypassword":
@@ -84,10 +153,27 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
case "proxyuser":
case "proxyUser": return java.lang.String.class;
case "region": return java.lang.String.class;
+ case "repeatcount":
+ case "repeatCount": return long.class;
+ case "runlogginglevel":
+ case "runLoggingLevel": return org.apache.camel.LoggingLevel.class;
+ case "scheduledexecutorservice":
+ case "scheduledExecutorService": return
java.util.concurrent.ScheduledExecutorService.class;
+ case "scheduler": return java.lang.Object.class;
+ case "schedulerproperties":
+ case "schedulerProperties": return java.util.Map.class;
case "secretkey":
case "secretKey": return java.lang.String.class;
+ case "sendemptymessagewhenidle":
+ case "sendEmptyMessageWhenIdle": return boolean.class;
case "servicekeys":
case "serviceKeys": return
org.apache.camel.component.huaweicloud.obs.models.ServiceKeys.class;
+ case "startscheduler":
+ case "startScheduler": return boolean.class;
+ case "timeunit":
+ case "timeUnit": return java.util.concurrent.TimeUnit.class;
+ case "usefixeddelay":
+ case "useFixedDelay": return boolean.class;
default: return null;
}
}
@@ -98,21 +184,47 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
switch (ignoreCase ? name.toLowerCase() : name) {
case "authenticationkey":
case "authenticationKey": return target.getAuthenticationKey();
+ case "backofferrorthreshold":
+ case "backoffErrorThreshold": return target.getBackoffErrorThreshold();
+ case "backoffidlethreshold":
+ case "backoffIdleThreshold": return target.getBackoffIdleThreshold();
+ case "backoffmultiplier":
+ case "backoffMultiplier": return target.getBackoffMultiplier();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
case "bucketlocation":
case "bucketLocation": return target.getBucketLocation();
case "bucketname":
case "bucketName": return target.getBucketName();
+ case "delay": return target.getDelay();
+ case "deleteafterread":
+ case "deleteAfterRead": return target.isDeleteAfterRead();
+ case "delimiter": return target.getDelimiter();
+ case "destinationbucket":
+ case "destinationBucket": return target.getDestinationBucket();
case "endpoint": return target.getEndpoint();
case "exceptionhandler":
case "exceptionHandler": return target.getExceptionHandler();
case "exchangepattern":
case "exchangePattern": return target.getExchangePattern();
+ case "filename":
+ case "fileName": return target.getFileName();
+ case "greedy": return target.isGreedy();
case "ignoresslverification":
case "ignoreSslVerification": return target.isIgnoreSslVerification();
+ case "includefolders":
+ case "includeFolders": return target.isIncludeFolders();
+ case "initialdelay":
+ case "initialDelay": return target.getInitialDelay();
case "lazystartproducer":
case "lazyStartProducer": return target.isLazyStartProducer();
+ case "maxmessagesperpoll":
+ case "maxMessagesPerPoll": return target.getMaxMessagesPerPoll();
+ case "moveafterread":
+ case "moveAfterRead": return target.isMoveAfterRead();
+ case "pollstrategy":
+ case "pollStrategy": return target.getPollStrategy();
+ case "prefix": return target.getPrefix();
case "proxyhost":
case "proxyHost": return target.getProxyHost();
case "proxypassword":
@@ -122,10 +234,36 @@ public class OBSEndpointConfigurer extends
PropertyConfigurerSupport implements
case "proxyuser":
case "proxyUser": return target.getProxyUser();
case "region": return target.getRegion();
+ case "repeatcount":
+ case "repeatCount": return target.getRepeatCount();
+ case "runlogginglevel":
+ case "runLoggingLevel": return target.getRunLoggingLevel();
+ case "scheduledexecutorservice":
+ case "scheduledExecutorService": return
target.getScheduledExecutorService();
+ case "scheduler": return target.getScheduler();
+ case "schedulerproperties":
+ case "schedulerProperties": return target.getSchedulerProperties();
case "secretkey":
case "secretKey": return target.getSecretKey();
+ case "sendemptymessagewhenidle":
+ case "sendEmptyMessageWhenIdle": return
target.isSendEmptyMessageWhenIdle();
case "servicekeys":
case "serviceKeys": return target.getServiceKeys();
+ case "startscheduler":
+ case "startScheduler": return target.isStartScheduler();
+ case "timeunit":
+ case "timeUnit": return target.getTimeUnit();
+ case "usefixeddelay":
+ case "useFixedDelay": return target.isUseFixedDelay();
+ default: return null;
+ }
+ }
+
+ @Override
+ public Object getCollectionValueType(Object target, String name, boolean
ignoreCase) {
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "schedulerproperties":
+ case "schedulerProperties": return java.lang.Object.class;
default: return null;
}
}
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
index c8cbdfd..52e7938 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/java/org/apache/camel/component/huaweicloud/obs/OBSEndpointUriFactory.java
@@ -20,20 +20,44 @@ public class OBSEndpointUriFactory 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<>(17);
+ Set<String> props = new HashSet<>(41);
+ props.add("backoffMultiplier");
props.add("bucketName");
+ props.add("destinationBucket");
+ props.add("fileName");
props.add("serviceKeys");
- props.add("secretKey");
+ props.add("prefix");
props.add("bucketLocation");
- props.add("proxyPassword");
- props.add("exchangePattern");
props.add("ignoreSslVerification");
- props.add("authenticationKey");
- props.add("proxyHost");
+ props.add("initialDelay");
+ props.add("scheduler");
props.add("proxyPort");
props.add("endpoint");
- props.add("lazyStartProducer");
props.add("bridgeErrorHandler");
+ props.add("useFixedDelay");
+ props.add("runLoggingLevel");
+ props.add("delimiter");
+ props.add("backoffErrorThreshold");
+ props.add("greedy");
+ props.add("maxMessagesPerPoll");
+ props.add("scheduledExecutorService");
+ props.add("repeatCount");
+ props.add("timeUnit");
+ props.add("secretKey");
+ props.add("moveAfterRead");
+ props.add("sendEmptyMessageWhenIdle");
+ props.add("schedulerProperties");
+ props.add("exchangePattern");
+ props.add("proxyPassword");
+ props.add("includeFolders");
+ props.add("authenticationKey");
+ props.add("proxyHost");
+ props.add("backoffIdleThreshold");
+ props.add("lazyStartProducer");
+ props.add("delay");
+ props.add("pollStrategy");
+ props.add("startScheduler");
+ props.add("deleteAfterRead");
props.add("proxyUser");
props.add("region");
props.add("operation");
diff --git
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
index 5da278f..eb664bb 100644
---
a/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
+++
b/components/camel-huawei/camel-huaweicloud-obs/src/generated/resources/org/apache/camel/component/huaweicloud/obs/hwcloud-obs.json
@@ -28,21 +28,45 @@
},
"properties": {
"operation": { "kind": "path", "displayName": "Operation", "group":
"producer", "label": "producer", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Operation to be performed"
},
- "authenticationKey": { "kind": "parameter", "displayName": "API
authentication key (AK)", "group": "common", "label": "", "required": true,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": true, "description":
"Authentication key for the cloud user" },
- "bucketLocation": { "kind": "parameter", "displayName": "Bucket Location",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Location of bucket when
creating a new bucket" },
"bucketName": { "kind": "parameter", "displayName": "Bucket Name",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Name of bucket to perform
operation on" },
"endpoint": { "kind": "parameter", "displayName": "Endpoint url", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "OBS url. Carries higher precedence than
region parameter based client initialization" },
- "ignoreSslVerification": { "kind": "parameter", "displayName": "SSL
Verification Ignored", "group": "common", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
false, "description": "Ignore SSL verification" },
- "proxyHost": { "kind": "parameter", "displayName": "Proxy server host",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Proxy server ip\/hostname"
},
- "proxyPassword": { "kind": "parameter", "displayName": "Proxy password",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": true, "description": "Proxy authentication
password" },
- "proxyPort": { "kind": "parameter", "displayName": "Proxy server port",
"group": "common", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Proxy server port" },
- "proxyUser": { "kind": "parameter", "displayName": "Proxy user", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": true, "description": "Proxy authentication user" },
"region": { "kind": "parameter", "displayName": "Service region", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "OBS service region. This is lower
precedence than endpoint based configuration" },
- "secretKey": { "kind": "parameter", "displayName": "API secret key (SK)",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": true, "description": "Secret key for the cloud user" },
- "serviceKeys": { "kind": "parameter", "displayName": "Service
Configuration", "group": "common", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.huaweicloud.obs.models.ServiceKeys", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": true,
"description": "Configuration object for cloud service authentication" },
"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 [...]
+ "deleteAfterRead": { "kind": "parameter", "displayName": "Delete after
read", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": false, "description":
"Determines if objects should be deleted after it has been retrieved" },
+ "delimiter": { "kind": "parameter", "displayName": "Delimiter", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The character used for
grouping object names" },
+ "destinationBucket": { "kind": "parameter", "displayName": "Destination
Bucket", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description":
"Name of destination bucket where objects will be moved when moveAfterRead is
set to true" },
+ "fileName": { "kind": "parameter", "displayName": "File Name", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Get the object from the
bucket with the given file name" },
+ "includeFolders": { "kind": "parameter", "displayName": "Include Folders",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": true, "description": "If true, objects
in folders will be consumed. Otherwise, they will be ignored and no Exchanges
will be created for them" },
+ "maxMessagesPerPoll": { "kind": "parameter", "displayName": "Maximum
messages per poll", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue": 10,
"description": "The maximum number of messages to poll at each polling" },
+ "moveAfterRead": { "kind": "parameter", "displayName": "Move After Read",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": false, "description": "Determines
whether objects should be moved to a different bucket after they have been
retrieved. The destinationBucket option must also be set for this option to
work." },
+ "prefix": { "kind": "parameter", "displayName": "Prefix", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The object name prefix
used for filtering objects to be listed" },
+ "sendEmptyMessageWhenIdle": { "kind": "parameter", "displayName": "Send
Empty Message When Idle", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "If
the polling consumer did not poll any files, you can enable this option to send
an empty message (no body) instead." },
"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." },
- "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 [...]
+ "pollStrategy": { "kind": "parameter", "displayName": "Poll Strategy",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation [...]
+ "bucketLocation": { "kind": "parameter", "displayName": "Bucket Location",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Location of bucket when
creating a new bucket" },
+ "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 [...]
+ "proxyHost": { "kind": "parameter", "displayName": "Proxy server host",
"group": "proxy", "label": "proxy", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Proxy server ip\/hostname"
},
+ "proxyPassword": { "kind": "parameter", "displayName": "Proxy password",
"group": "proxy", "label": "proxy", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": true, "description": "Proxy authentication
password" },
+ "proxyPort": { "kind": "parameter", "displayName": "Proxy server port",
"group": "proxy", "label": "proxy", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Proxy server port" },
+ "proxyUser": { "kind": "parameter", "displayName": "Proxy user", "group":
"proxy", "label": "proxy", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": true, "description": "Proxy authentication user" },
+ "backoffErrorThreshold": { "kind": "parameter", "displayName": "Backoff
Error Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
error polls (failed due some error) that should happen before the
backoffMultipler should kick-in." },
+ "backoffIdleThreshold": { "kind": "parameter", "displayName": "Backoff
Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
+ "backoffMultiplier": { "kind": "parameter", "displayName": "Backoff
Multiplier", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "description": "To let the scheduled polling consumer
backoff if there has been a number of subsequent idles\/errors in a row. The
multiplier is then the number of polls that will be skipped before the next
actual attempt is happening agai [...]
+ "delay": { "kind": "parameter", "displayName": "Delay", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
+ "greedy": { "kind": "parameter", "displayName": "Greedy", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
+ "initialDelay": { "kind": "parameter", "displayName": "Initial Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "description": "Milliseconds before the
first poll starts." },
+ "repeatCount": { "kind": "parameter", "displayName": "Repeat Count",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
+ "runLoggingLevel": { "kind": "parameter", "displayName": "Run Logging
Level", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "org.apache.camel.LoggingLevel", "enum": [
"TRACE", "DEBUG", "INFO", "WARN", "ERROR", "OFF" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "TRACE", "description":
"The consumer logs a start\/complete log line when it polls. This option allows
you to configure the logging level [...]
+ "scheduledExecutorService": { "kind": "parameter", "displayName":
"Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
+ "scheduler": { "kind": "parameter", "displayName": "Scheduler", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"object", "javaType": "java.lang.Object", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "none", "description": "To use a cron
scheduler from either camel-spring or camel-quartz component. Use value spring
or quartz for built in scheduler" },
+ "schedulerProperties": { "kind": "parameter", "displayName": "Scheduler
Properties", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.util.Map<java.lang.String,
java.lang.Object>", "prefix": "scheduler.", "multiValue": true, "deprecated":
false, "autowired": false, "secret": false, "description": "To configure
additional properties when using a custom scheduler or any of the Quartz,
Spring based scheduler." },
+ "startScheduler": { "kind": "parameter", "displayName": "Start Scheduler",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether the scheduler
should be auto started." },
+ "timeUnit": { "kind": "parameter", "displayName": "Time Unit", "group":
"scheduler", "label": "consumer,scheduler", "required": false, "type":
"object", "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS",
"MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"MILLISECONDS", "description": "Time unit for initialDelay and delay options."
},
+ "useFixedDelay": { "kind": "parameter", "displayName": "Use Fixed Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Controls if fixed delay
or fixed rate is used. See ScheduledExecutorService in JDK for details." },
+ "authenticationKey": { "kind": "parameter", "displayName": "API
authentication key (AK)", "group": "security", "label": "security", "required":
true, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": true, "description":
"Authentication key for the cloud user" },
+ "ignoreSslVerification": { "kind": "parameter", "displayName": "SSL
Verification Ignored", "group": "security", "label": "security", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "defaultValue":
false, "description": "Ignore SSL verification" },
+ "secretKey": { "kind": "parameter", "displayName": "API secret key (SK)",
"group": "security", "label": "security", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": true, "description": "Secret key for the cloud
user" },
+ "serviceKeys": { "kind": "parameter", "displayName": "Service
Configuration", "group": "security", "label": "security", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.huaweicloud.obs.models.ServiceKeys", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": true,
"description": "Configuration object for cloud service authentication" }
}
}
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
index e88ba90..b42d56f 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/OBSEndpointBuilderFactory.java
@@ -16,12 +16,17 @@
*/
package org.apache.camel.builder.endpoint.dsl;
+import java.util.Map;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
import org.apache.camel.ExchangePattern;
+import org.apache.camel.LoggingLevel;
import org.apache.camel.builder.EndpointConsumerBuilder;
import org.apache.camel.builder.EndpointProducerBuilder;
import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
import org.apache.camel.spi.ExceptionHandler;
+import org.apache.camel.spi.PollingConsumerPollStrategy;
/**
* To provide stable, secure, efficient, and easy-to-use cloud storage service
@@ -44,181 +49,911 @@ public interface OBSEndpointBuilderFactory {
return (AdvancedOBSEndpointConsumerBuilder) this;
}
/**
- * Authentication key for the cloud user.
+ * Name of bucket to perform operation on.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param bucketName the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder bucketName(String bucketName) {
+ doSetProperty("bucketName", bucketName);
+ return this;
+ }
+ /**
+ * OBS url. Carries higher precedence than region parameter based
client
+ * initialization.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param endpoint the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder endpoint(String endpoint) {
+ doSetProperty("endpoint", endpoint);
+ return this;
+ }
+ /**
+ * OBS service region. This is lower precedence than endpoint based
+ * configuration.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Required: true
+ * Group: common
+ *
+ * @param region the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder region(String region) {
+ doSetProperty("region", region);
+ 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 is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder 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 OBSEndpointConsumerBuilder bridgeErrorHandler(
+ String bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * Determines if objects should be deleted after it has been retrieved.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param deleteAfterRead the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder deleteAfterRead(
+ boolean deleteAfterRead) {
+ doSetProperty("deleteAfterRead", deleteAfterRead);
+ return this;
+ }
+ /**
+ * Determines if objects should be deleted after it has been retrieved.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param deleteAfterRead the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder deleteAfterRead(
+ String deleteAfterRead) {
+ doSetProperty("deleteAfterRead", deleteAfterRead);
+ return this;
+ }
+ /**
+ * The character used for grouping object names.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param delimiter the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder delimiter(String delimiter) {
+ doSetProperty("delimiter", delimiter);
+ return this;
+ }
+ /**
+ * Name of destination bucket where objects will be moved when
+ * moveAfterRead is set to true.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param destinationBucket the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder destinationBucket(
+ String destinationBucket) {
+ doSetProperty("destinationBucket", destinationBucket);
+ return this;
+ }
+ /**
+ * Get the object from the bucket with the given file name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param fileName the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder fileName(String fileName) {
+ doSetProperty("fileName", fileName);
+ return this;
+ }
+ /**
+ * If true, objects in folders will be consumed. Otherwise, they will
be
+ * ignored and no Exchanges will be created for them.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: consumer
+ *
+ * @param includeFolders the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder includeFolders(boolean
includeFolders) {
+ doSetProperty("includeFolders", includeFolders);
+ return this;
+ }
+ /**
+ * If true, objects in folders will be consumed. Otherwise, they will
be
+ * ignored and no Exchanges will be created for them.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: consumer
+ *
+ * @param includeFolders the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder includeFolders(String
includeFolders) {
+ doSetProperty("includeFolders", includeFolders);
+ return this;
+ }
+ /**
+ * The maximum number of messages to poll at each polling.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 10
+ * Group: consumer
+ *
+ * @param maxMessagesPerPoll the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder maxMessagesPerPoll(
+ int maxMessagesPerPoll) {
+ doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
+ return this;
+ }
+ /**
+ * The maximum number of messages to poll at each polling.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 10
+ * Group: consumer
+ *
+ * @param maxMessagesPerPoll the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder maxMessagesPerPoll(
+ String maxMessagesPerPoll) {
+ doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
+ return this;
+ }
+ /**
+ * Determines whether objects should be moved to a different bucket
+ * after they have been retrieved. The destinationBucket option must
+ * also be set for this option to work.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param moveAfterRead the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder moveAfterRead(boolean
moveAfterRead) {
+ doSetProperty("moveAfterRead", moveAfterRead);
+ return this;
+ }
+ /**
+ * Determines whether objects should be moved to a different bucket
+ * after they have been retrieved. The destinationBucket option must
+ * also be set for this option to work.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param moveAfterRead the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder moveAfterRead(String moveAfterRead)
{
+ doSetProperty("moveAfterRead", moveAfterRead);
+ return this;
+ }
+ /**
+ * The object name prefix used for filtering objects to be listed.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param prefix the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder prefix(String prefix) {
+ doSetProperty("prefix", prefix);
+ return this;
+ }
+ /**
+ * If the polling consumer did not poll any files, you can enable this
+ * option to send an empty message (no body) instead.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param sendEmptyMessageWhenIdle the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder sendEmptyMessageWhenIdle(
+ boolean sendEmptyMessageWhenIdle) {
+ doSetProperty("sendEmptyMessageWhenIdle",
sendEmptyMessageWhenIdle);
+ return this;
+ }
+ /**
+ * If the polling consumer did not poll any files, you can enable this
+ * option to send an empty message (no body) instead.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param sendEmptyMessageWhenIdle the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder sendEmptyMessageWhenIdle(
+ String sendEmptyMessageWhenIdle) {
+ doSetProperty("sendEmptyMessageWhenIdle",
sendEmptyMessageWhenIdle);
+ return this;
+ }
+ /**
+ * Proxy server ip/hostname.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: proxy
+ *
+ * @param proxyHost the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder proxyHost(String proxyHost) {
+ doSetProperty("proxyHost", proxyHost);
+ return this;
+ }
+ /**
+ * Proxy authentication password.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: proxy
+ *
+ * @param proxyPassword the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder proxyPassword(String proxyPassword)
{
+ doSetProperty("proxyPassword", proxyPassword);
+ return this;
+ }
+ /**
+ * Proxy server port.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: proxy
+ *
+ * @param proxyPort the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder proxyPort(int proxyPort) {
+ doSetProperty("proxyPort", proxyPort);
+ return this;
+ }
+ /**
+ * Proxy server port.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: proxy
+ *
+ * @param proxyPort the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder proxyPort(String proxyPort) {
+ doSetProperty("proxyPort", proxyPort);
+ return this;
+ }
+ /**
+ * Proxy authentication user.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: proxy
+ *
+ * @param proxyUser the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder proxyUser(String proxyUser) {
+ doSetProperty("proxyUser", proxyUser);
+ return this;
+ }
+ /**
+ * The number of subsequent error polls (failed due some error) that
+ * should happen before the backoffMultipler should kick-in.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param backoffErrorThreshold the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder backoffErrorThreshold(
+ int backoffErrorThreshold) {
+ doSetProperty("backoffErrorThreshold", backoffErrorThreshold);
+ return this;
+ }
+ /**
+ * The number of subsequent error polls (failed due some error) that
+ * should happen before the backoffMultipler should kick-in.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param backoffErrorThreshold the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder backoffErrorThreshold(
+ String backoffErrorThreshold) {
+ doSetProperty("backoffErrorThreshold", backoffErrorThreshold);
+ return this;
+ }
+ /**
+ * The number of subsequent idle polls that should happen before the
+ * backoffMultipler should kick-in.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param backoffIdleThreshold the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder backoffIdleThreshold(
+ int backoffIdleThreshold) {
+ doSetProperty("backoffIdleThreshold", backoffIdleThreshold);
+ return this;
+ }
+ /**
+ * The number of subsequent idle polls that should happen before the
+ * backoffMultipler should kick-in.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param backoffIdleThreshold the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder backoffIdleThreshold(
+ String backoffIdleThreshold) {
+ doSetProperty("backoffIdleThreshold", backoffIdleThreshold);
+ return this;
+ }
+ /**
+ * To let the scheduled polling consumer backoff if there has been a
+ * number of subsequent idles/errors in a row. The multiplier is then
+ * the number of polls that will be skipped before the next actual
+ * attempt is happening again. When this option is in use then
+ * backoffIdleThreshold and/or backoffErrorThreshold must also be
+ * configured.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param backoffMultiplier the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder backoffMultiplier(
+ int backoffMultiplier) {
+ doSetProperty("backoffMultiplier", backoffMultiplier);
+ return this;
+ }
+ /**
+ * To let the scheduled polling consumer backoff if there has been a
+ * number of subsequent idles/errors in a row. The multiplier is then
+ * the number of polls that will be skipped before the next actual
+ * attempt is happening again. When this option is in use then
+ * backoffIdleThreshold and/or backoffErrorThreshold must also be
+ * configured.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param backoffMultiplier the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder backoffMultiplier(
+ String backoffMultiplier) {
+ doSetProperty("backoffMultiplier", backoffMultiplier);
+ return this;
+ }
+ /**
+ * Milliseconds before the next poll.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500
+ * Group: scheduler
+ *
+ * @param delay the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder delay(long delay) {
+ doSetProperty("delay", delay);
+ return this;
+ }
+ /**
+ * Milliseconds before the next poll.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 500
+ * Group: scheduler
+ *
+ * @param delay the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder delay(String delay) {
+ doSetProperty("delay", delay);
+ return this;
+ }
+ /**
+ * If greedy is enabled, then the ScheduledPollConsumer will run
+ * immediately again, if the previous run polled 1 or more messages.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: scheduler
+ *
+ * @param greedy the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder greedy(boolean greedy) {
+ doSetProperty("greedy", greedy);
+ return this;
+ }
+ /**
+ * If greedy is enabled, then the ScheduledPollConsumer will run
+ * immediately again, if the previous run polled 1 or more messages.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: scheduler
+ *
+ * @param greedy the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder greedy(String greedy) {
+ doSetProperty("greedy", greedy);
+ return this;
+ }
+ /**
+ * Milliseconds before the first poll starts.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: scheduler
+ *
+ * @param initialDelay the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder initialDelay(long initialDelay) {
+ doSetProperty("initialDelay", initialDelay);
+ return this;
+ }
+ /**
+ * Milliseconds before the first poll starts.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 1000
+ * Group: scheduler
+ *
+ * @param initialDelay the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder initialDelay(String initialDelay) {
+ doSetProperty("initialDelay", initialDelay);
+ return this;
+ }
+ /**
+ * Specifies a maximum limit of number of fires. So if you set it to 1,
+ * the scheduler will only fire once. If you set it to 5, it will only
+ * fire five times. A value of zero or negative means fire forever.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: scheduler
+ *
+ * @param repeatCount the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder repeatCount(long repeatCount) {
+ doSetProperty("repeatCount", repeatCount);
+ return this;
+ }
+ /**
+ * Specifies a maximum limit of number of fires. So if you set it to 1,
+ * the scheduler will only fire once. If you set it to 5, it will only
+ * fire five times. A value of zero or negative means fire forever.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option will be converted to a <code>long</code>
type.
*
- * Required: true
- * Group: common
+ * Default: 0
+ * Group: scheduler
*
- * @param authenticationKey the value to set
+ * @param repeatCount the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder authenticationKey(
- String authenticationKey) {
- doSetProperty("authenticationKey", authenticationKey);
+ default OBSEndpointConsumerBuilder repeatCount(String repeatCount) {
+ doSetProperty("repeatCount", repeatCount);
return this;
}
/**
- * Location of bucket when creating a new bucket.
+ * The consumer logs a start/complete log line when it polls. This
+ * option allows you to configure the logging level for that.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option is a:
+ * <code>org.apache.camel.LoggingLevel</code> type.
*
- * Group: common
+ * Default: TRACE
+ * Group: scheduler
*
- * @param bucketLocation the value to set
+ * @param runLoggingLevel the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder bucketLocation(String
bucketLocation) {
- doSetProperty("bucketLocation", bucketLocation);
+ default OBSEndpointConsumerBuilder runLoggingLevel(
+ LoggingLevel runLoggingLevel) {
+ doSetProperty("runLoggingLevel", runLoggingLevel);
return this;
}
/**
- * Name of bucket to perform operation on.
+ * The consumer logs a start/complete log line when it polls. This
+ * option allows you to configure the logging level for that.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option will be converted to a
+ * <code>org.apache.camel.LoggingLevel</code> type.
*
- * Group: common
+ * Default: TRACE
+ * Group: scheduler
*
- * @param bucketName the value to set
+ * @param runLoggingLevel the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder bucketName(String bucketName) {
- doSetProperty("bucketName", bucketName);
+ default OBSEndpointConsumerBuilder runLoggingLevel(
+ String runLoggingLevel) {
+ doSetProperty("runLoggingLevel", runLoggingLevel);
return this;
}
/**
- * OBS url. Carries higher precedence than region parameter based
client
- * initialization.
+ * Allows for configuring a custom/shared thread pool to use for the
+ * consumer. By default each consumer has its own single threaded
thread
+ * pool.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option is a:
+ *
<code>java.util.concurrent.ScheduledExecutorService</code> type.
*
- * Group: common
+ * Group: scheduler
*
- * @param endpoint the value to set
+ * @param scheduledExecutorService the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder endpoint(String endpoint) {
- doSetProperty("endpoint", endpoint);
+ default OBSEndpointConsumerBuilder scheduledExecutorService(
+ ScheduledExecutorService scheduledExecutorService) {
+ doSetProperty("scheduledExecutorService",
scheduledExecutorService);
return this;
}
/**
- * Ignore SSL verification.
+ * Allows for configuring a custom/shared thread pool to use for the
+ * consumer. By default each consumer has its own single threaded
thread
+ * pool.
+ *
+ * The option will be converted to a
+ *
<code>java.util.concurrent.ScheduledExecutorService</code> type.
+ *
+ * Group: scheduler
+ *
+ * @param scheduledExecutorService the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder scheduledExecutorService(
+ String scheduledExecutorService) {
+ doSetProperty("scheduledExecutorService",
scheduledExecutorService);
+ return this;
+ }
+ /**
+ * To use a cron scheduler from either camel-spring or camel-quartz
+ * component. Use value spring or quartz for built in scheduler.
+ *
+ * The option is a: <code>java.lang.Object</code> type.
+ *
+ * Default: none
+ * Group: scheduler
+ *
+ * @param scheduler the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder scheduler(Object scheduler) {
+ doSetProperty("scheduler", scheduler);
+ return this;
+ }
+ /**
+ * To use a cron scheduler from either camel-spring or camel-quartz
+ * component. Use value spring or quartz for built in scheduler.
+ *
+ * The option will be converted to a
+ * <code>java.lang.Object</code> type.
+ *
+ * Default: none
+ * Group: scheduler
+ *
+ * @param scheduler the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder scheduler(String scheduler) {
+ doSetProperty("scheduler", scheduler);
+ return this;
+ }
+ /**
+ * To configure additional properties when using a custom scheduler or
+ * any of the Quartz, Spring based scheduler.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.Object&gt;</code> type.
+ * The option is multivalued, and you can use the
+ * schedulerProperties(String, Object) method to add a value (call the
+ * method multiple times to set more values).
+ *
+ * Group: scheduler
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder schedulerProperties(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("schedulerProperties", "scheduler." + key,
value);
+ return this;
+ }
+ /**
+ * To configure additional properties when using a custom scheduler or
+ * any of the Quartz, Spring based scheduler.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.Object&gt;</code> type.
+ * The option is multivalued, and you can use the
+ * schedulerProperties(String, Object) method to add a value (call the
+ * method multiple times to set more values).
+ *
+ * Group: scheduler
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder schedulerProperties(Map values) {
+ doSetMultiValueProperties("schedulerProperties", "scheduler.",
values);
+ return this;
+ }
+ /**
+ * Whether the scheduler should be auto started.
*
* The option is a: <code>boolean</code> type.
*
- * Default: false
- * Group: common
+ * Default: true
+ * Group: scheduler
*
- * @param ignoreSslVerification the value to set
+ * @param startScheduler the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder ignoreSslVerification(
- boolean ignoreSslVerification) {
- doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ default OBSEndpointConsumerBuilder startScheduler(boolean
startScheduler) {
+ doSetProperty("startScheduler", startScheduler);
return this;
}
/**
- * Ignore SSL verification.
+ * Whether the scheduler should be auto started.
*
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: false
- * Group: common
+ * Default: true
+ * Group: scheduler
*
- * @param ignoreSslVerification the value to set
+ * @param startScheduler the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder ignoreSslVerification(
- String ignoreSslVerification) {
- doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ default OBSEndpointConsumerBuilder startScheduler(String
startScheduler) {
+ doSetProperty("startScheduler", startScheduler);
return this;
}
/**
- * Proxy server ip/hostname.
+ * Time unit for initialDelay and delay options.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option is a:
+ * <code>java.util.concurrent.TimeUnit</code> type.
*
- * Group: common
+ * Default: MILLISECONDS
+ * Group: scheduler
*
- * @param proxyHost the value to set
+ * @param timeUnit the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder proxyHost(String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
+ default OBSEndpointConsumerBuilder timeUnit(TimeUnit timeUnit) {
+ doSetProperty("timeUnit", timeUnit);
return this;
}
/**
- * Proxy authentication password.
+ * Time unit for initialDelay and delay options.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option will be converted to a
+ * <code>java.util.concurrent.TimeUnit</code> type.
*
- * Group: common
+ * Default: MILLISECONDS
+ * Group: scheduler
*
- * @param proxyPassword the value to set
+ * @param timeUnit the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder proxyPassword(String proxyPassword)
{
- doSetProperty("proxyPassword", proxyPassword);
+ default OBSEndpointConsumerBuilder timeUnit(String timeUnit) {
+ doSetProperty("timeUnit", timeUnit);
return this;
}
/**
- * Proxy server port.
+ * Controls if fixed delay or fixed rate is used. See
+ * ScheduledExecutorService in JDK for details.
*
- * The option is a: <code>int</code> type.
+ * The option is a: <code>boolean</code> type.
*
- * Group: common
+ * Default: true
+ * Group: scheduler
*
- * @param proxyPort the value to set
+ * @param useFixedDelay the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder proxyPort(int proxyPort) {
- doSetProperty("proxyPort", proxyPort);
+ default OBSEndpointConsumerBuilder useFixedDelay(boolean
useFixedDelay) {
+ doSetProperty("useFixedDelay", useFixedDelay);
return this;
}
/**
- * Proxy server port.
+ * Controls if fixed delay or fixed rate is used. See
+ * ScheduledExecutorService in JDK for details.
*
- * The option will be converted to a <code>int</code> type.
+ * The option will be converted to a <code>boolean</code>
+ * type.
*
- * Group: common
+ * Default: true
+ * Group: scheduler
*
- * @param proxyPort the value to set
+ * @param useFixedDelay the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder proxyPort(String proxyPort) {
- doSetProperty("proxyPort", proxyPort);
+ default OBSEndpointConsumerBuilder useFixedDelay(String useFixedDelay)
{
+ doSetProperty("useFixedDelay", useFixedDelay);
return this;
}
/**
- * Proxy authentication user.
+ * Authentication key for the cloud user.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Required: true
+ * Group: security
*
- * @param proxyUser the value to set
+ * @param authenticationKey the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder proxyUser(String proxyUser) {
- doSetProperty("proxyUser", proxyUser);
+ default OBSEndpointConsumerBuilder authenticationKey(
+ String authenticationKey) {
+ doSetProperty("authenticationKey", authenticationKey);
return this;
}
/**
- * OBS service region. This is lower precedence than endpoint based
- * configuration.
+ * Ignore SSL verification.
*
- * The option is a: <code>java.lang.String</code> type.
+ * The option is a: <code>boolean</code> type.
*
- * Required: true
- * Group: common
+ * Default: false
+ * Group: security
*
- * @param region the value to set
+ * @param ignoreSslVerification the value to set
* @return the dsl builder
*/
- default OBSEndpointConsumerBuilder region(String region) {
- doSetProperty("region", region);
+ default OBSEndpointConsumerBuilder ignoreSslVerification(
+ boolean ignoreSslVerification) {
+ doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ return this;
+ }
+ /**
+ * Ignore SSL verification.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param ignoreSslVerification the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointConsumerBuilder ignoreSslVerification(
+ String ignoreSslVerification) {
+ doSetProperty("ignoreSslVerification", ignoreSslVerification);
return this;
}
/**
@@ -227,7 +962,7 @@ public interface OBSEndpointBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Required: true
- * Group: common
+ * Group: security
*
* @param secretKey the value to set
* @return the dsl builder
@@ -242,7 +977,7 @@ public interface OBSEndpointBuilderFactory {
* The option is a:
*
<code>org.apache.camel.component.huaweicloud.obs.models.ServiceKeys</code>
type.
*
- * Group: common
+ * Group: security
*
* @param serviceKeys the value to set
* @return the dsl builder
@@ -257,7 +992,7 @@ public interface OBSEndpointBuilderFactory {
* The option will be converted to a
*
<code>org.apache.camel.component.huaweicloud.obs.models.ServiceKeys</code>
type.
*
- * Group: common
+ * Group: security
*
* @param serviceKeys the value to set
* @return the dsl builder
@@ -266,51 +1001,6 @@ public interface OBSEndpointBuilderFactory {
doSetProperty("serviceKeys", serviceKeys);
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 is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default OBSEndpointConsumerBuilder 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 OBSEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
}
/**
@@ -393,6 +1083,44 @@ public interface OBSEndpointBuilderFactory {
doSetProperty("exchangePattern", exchangePattern);
return this;
}
+ /**
+ * A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing
+ * you to provide your custom implementation to control error handling
+ * usually occurred during the poll operation before an Exchange have
+ * been created and being routed in Camel.
+ *
+ * The option is a:
+ *
<code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param pollStrategy the value to set
+ * @return the dsl builder
+ */
+ default AdvancedOBSEndpointConsumerBuilder pollStrategy(
+ PollingConsumerPollStrategy pollStrategy) {
+ doSetProperty("pollStrategy", pollStrategy);
+ return this;
+ }
+ /**
+ * A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing
+ * you to provide your custom implementation to control error handling
+ * usually occurred during the poll operation before an Exchange have
+ * been created and being routed in Camel.
+ *
+ * The option will be converted to a
+ *
<code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param pollStrategy the value to set
+ * @return the dsl builder
+ */
+ default AdvancedOBSEndpointConsumerBuilder pollStrategy(
+ String pollStrategy) {
+ doSetProperty("pollStrategy", pollStrategy);
+ return this;
+ }
}
/**
@@ -406,95 +1134,111 @@ public interface OBSEndpointBuilderFactory {
return (AdvancedOBSEndpointProducerBuilder) this;
}
/**
- * Authentication key for the cloud user.
+ * Name of bucket to perform operation on.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Required: true
* Group: common
*
- * @param authenticationKey the value to set
+ * @param bucketName the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder authenticationKey(
- String authenticationKey) {
- doSetProperty("authenticationKey", authenticationKey);
+ default OBSEndpointProducerBuilder bucketName(String bucketName) {
+ doSetProperty("bucketName", bucketName);
return this;
}
/**
- * Location of bucket when creating a new bucket.
+ * OBS url. Carries higher precedence than region parameter based
client
+ * initialization.
*
* The option is a: <code>java.lang.String</code> type.
*
* Group: common
*
- * @param bucketLocation the value to set
+ * @param endpoint the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder bucketLocation(String
bucketLocation) {
- doSetProperty("bucketLocation", bucketLocation);
+ default OBSEndpointProducerBuilder endpoint(String endpoint) {
+ doSetProperty("endpoint", endpoint);
return this;
}
/**
- * Name of bucket to perform operation on.
+ * OBS service region. This is lower precedence than endpoint based
+ * configuration.
*
* The option is a: <code>java.lang.String</code> type.
*
+ * Required: true
* Group: common
*
- * @param bucketName the value to set
+ * @param region the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder bucketName(String bucketName) {
- doSetProperty("bucketName", bucketName);
+ default OBSEndpointProducerBuilder region(String region) {
+ doSetProperty("region", region);
return this;
}
/**
- * OBS url. Carries higher precedence than region parameter based
client
- * initialization.
+ * Location of bucket when creating a new bucket.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: producer
*
- * @param endpoint the value to set
+ * @param bucketLocation the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder endpoint(String endpoint) {
- doSetProperty("endpoint", endpoint);
+ default OBSEndpointProducerBuilder bucketLocation(String
bucketLocation) {
+ doSetProperty("bucketLocation", bucketLocation);
return this;
}
/**
- * Ignore SSL verification.
+ * 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 starting the
+ * producer may take a little time and prolong the total processing
time
+ * of the processing.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
- * Group: common
+ * Group: producer
*
- * @param ignoreSslVerification the value to set
+ * @param lazyStartProducer the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder ignoreSslVerification(
- boolean ignoreSslVerification) {
- doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ default OBSEndpointProducerBuilder lazyStartProducer(
+ boolean lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
return this;
}
/**
- * Ignore SSL verification.
+ * 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 starting the
+ * producer may take a little time and prolong the total processing
time
+ * of the processing.
*
* The option will be converted to a <code>boolean</code>
* type.
*
* Default: false
- * Group: common
+ * Group: producer
*
- * @param ignoreSslVerification the value to set
+ * @param lazyStartProducer the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder ignoreSslVerification(
- String ignoreSslVerification) {
- doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ default OBSEndpointProducerBuilder lazyStartProducer(
+ String lazyStartProducer) {
+ doSetProperty("lazyStartProducer", lazyStartProducer);
return this;
}
/**
@@ -502,7 +1246,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyHost the value to set
* @return the dsl builder
@@ -516,7 +1260,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyPassword the value to set
* @return the dsl builder
@@ -530,7 +1274,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>int</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyPort the value to set
* @return the dsl builder
@@ -544,7 +1288,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option will be converted to a <code>int</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyPort the value to set
* @return the dsl builder
@@ -558,7 +1302,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyUser the value to set
* @return the dsl builder
@@ -568,19 +1312,52 @@ public interface OBSEndpointBuilderFactory {
return this;
}
/**
- * OBS service region. This is lower precedence than endpoint based
- * configuration.
+ * Authentication key for the cloud user.
*
* The option is a: <code>java.lang.String</code> type.
*
* Required: true
- * Group: common
+ * Group: security
*
- * @param region the value to set
+ * @param authenticationKey the value to set
* @return the dsl builder
*/
- default OBSEndpointProducerBuilder region(String region) {
- doSetProperty("region", region);
+ default OBSEndpointProducerBuilder authenticationKey(
+ String authenticationKey) {
+ doSetProperty("authenticationKey", authenticationKey);
+ return this;
+ }
+ /**
+ * Ignore SSL verification.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param ignoreSslVerification the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointProducerBuilder ignoreSslVerification(
+ boolean ignoreSslVerification) {
+ doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ return this;
+ }
+ /**
+ * Ignore SSL verification.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param ignoreSslVerification the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointProducerBuilder ignoreSslVerification(
+ String ignoreSslVerification) {
+ doSetProperty("ignoreSslVerification", ignoreSslVerification);
return this;
}
/**
@@ -589,7 +1366,7 @@ public interface OBSEndpointBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Required: true
- * Group: common
+ * Group: security
*
* @param secretKey the value to set
* @return the dsl builder
@@ -604,7 +1381,7 @@ public interface OBSEndpointBuilderFactory {
* The option is a:
*
<code>org.apache.camel.component.huaweicloud.obs.models.ServiceKeys</code>
type.
*
- * Group: common
+ * Group: security
*
* @param serviceKeys the value to set
* @return the dsl builder
@@ -619,7 +1396,7 @@ public interface OBSEndpointBuilderFactory {
* The option will be converted to a
*
<code>org.apache.camel.component.huaweicloud.obs.models.ServiceKeys</code>
type.
*
- * Group: common
+ * Group: security
*
* @param serviceKeys the value to set
* @return the dsl builder
@@ -628,55 +1405,6 @@ public interface OBSEndpointBuilderFactory {
doSetProperty("serviceKeys", serviceKeys);
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
- * 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 starting the
- * producer may take a little time and prolong the total processing
time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default OBSEndpointProducerBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- 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
- * 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 starting the
- * producer may take a little time and prolong the total processing
time
- * of the processing.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default OBSEndpointProducerBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
}
/**
@@ -703,35 +1431,6 @@ public interface OBSEndpointBuilderFactory {
return (AdvancedOBSEndpointBuilder) this;
}
/**
- * Authentication key for the cloud user.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Required: true
- * Group: common
- *
- * @param authenticationKey the value to set
- * @return the dsl builder
- */
- default OBSEndpointBuilder authenticationKey(String authenticationKey)
{
- doSetProperty("authenticationKey", authenticationKey);
- return this;
- }
- /**
- * Location of bucket when creating a new bucket.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param bucketLocation the value to set
- * @return the dsl builder
- */
- default OBSEndpointBuilder bucketLocation(String bucketLocation) {
- doSetProperty("bucketLocation", bucketLocation);
- return this;
- }
- /**
* Name of bucket to perform operation on.
*
* The option is a: <code>java.lang.String</code> type.
@@ -761,36 +1460,19 @@ public interface OBSEndpointBuilderFactory {
return this;
}
/**
- * Ignore SSL verification.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: common
- *
- * @param ignoreSslVerification the value to set
- * @return the dsl builder
- */
- default OBSEndpointBuilder ignoreSslVerification(
- boolean ignoreSslVerification) {
- doSetProperty("ignoreSslVerification", ignoreSslVerification);
- return this;
- }
- /**
- * Ignore SSL verification.
+ * OBS service region. This is lower precedence than endpoint based
+ * configuration.
*
- * The option will be converted to a <code>boolean</code>
- * type.
+ * The option is a: <code>java.lang.String</code> type.
*
- * Default: false
+ * Required: true
* Group: common
*
- * @param ignoreSslVerification the value to set
+ * @param region the value to set
* @return the dsl builder
*/
- default OBSEndpointBuilder ignoreSslVerification(
- String ignoreSslVerification) {
- doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ default OBSEndpointBuilder region(String region) {
+ doSetProperty("region", region);
return this;
}
/**
@@ -798,7 +1480,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyHost the value to set
* @return the dsl builder
@@ -812,7 +1494,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyPassword the value to set
* @return the dsl builder
@@ -826,7 +1508,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>int</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyPort the value to set
* @return the dsl builder
@@ -840,7 +1522,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option will be converted to a <code>int</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyPort the value to set
* @return the dsl builder
@@ -854,7 +1536,7 @@ public interface OBSEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Group: common
+ * Group: proxy
*
* @param proxyUser the value to set
* @return the dsl builder
@@ -864,19 +1546,51 @@ public interface OBSEndpointBuilderFactory {
return this;
}
/**
- * OBS service region. This is lower precedence than endpoint based
- * configuration.
+ * Authentication key for the cloud user.
*
* The option is a: <code>java.lang.String</code> type.
*
* Required: true
- * Group: common
+ * Group: security
*
- * @param region the value to set
+ * @param authenticationKey the value to set
* @return the dsl builder
*/
- default OBSEndpointBuilder region(String region) {
- doSetProperty("region", region);
+ default OBSEndpointBuilder authenticationKey(String authenticationKey)
{
+ doSetProperty("authenticationKey", authenticationKey);
+ return this;
+ }
+ /**
+ * Ignore SSL verification.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param ignoreSslVerification the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointBuilder ignoreSslVerification(
+ boolean ignoreSslVerification) {
+ doSetProperty("ignoreSslVerification", ignoreSslVerification);
+ return this;
+ }
+ /**
+ * Ignore SSL verification.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: security
+ *
+ * @param ignoreSslVerification the value to set
+ * @return the dsl builder
+ */
+ default OBSEndpointBuilder ignoreSslVerification(
+ String ignoreSslVerification) {
+ doSetProperty("ignoreSslVerification", ignoreSslVerification);
return this;
}
/**
@@ -885,7 +1599,7 @@ public interface OBSEndpointBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Required: true
- * Group: common
+ * Group: security
*
* @param secretKey the value to set
* @return the dsl builder
@@ -900,7 +1614,7 @@ public interface OBSEndpointBuilderFactory {
* The option is a:
*
<code>org.apache.camel.component.huaweicloud.obs.models.ServiceKeys</code>
type.
*
- * Group: common
+ * Group: security
*
* @param serviceKeys the value to set
* @return the dsl builder
@@ -915,7 +1629,7 @@ public interface OBSEndpointBuilderFactory {
* The option will be converted to a
*
<code>org.apache.camel.component.huaweicloud.obs.models.ServiceKeys</code>
type.
*
- * Group: common
+ * Group: security
*
* @param serviceKeys the value to set
* @return the dsl builder
diff --git a/docs/components/modules/ROOT/pages/hwcloud-obs-component.adoc
b/docs/components/modules/ROOT/pages/hwcloud-obs-component.adoc
index 60630fd..4e77141 100644
--- a/docs/components/modules/ROOT/pages/hwcloud-obs-component.adoc
+++ b/docs/components/modules/ROOT/pages/hwcloud-obs-component.adoc
@@ -72,28 +72,52 @@ with the following path and query parameters:
|===
-=== Query Parameters (16 parameters):
+=== Query Parameters (40 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *authenticationKey* (common) | *Required* Authentication key for the cloud
user | | String
-| *bucketLocation* (common) | Location of bucket when creating a new bucket |
| String
| *bucketName* (common) | Name of bucket to perform operation on | | String
| *endpoint* (common) | OBS url. Carries higher precedence than region
parameter based client initialization | | String
-| *ignoreSslVerification* (common) | Ignore SSL verification | false | boolean
-| *proxyHost* (common) | Proxy server ip/hostname | | String
-| *proxyPassword* (common) | Proxy authentication password | | String
-| *proxyPort* (common) | Proxy server port | | int
-| *proxyUser* (common) | Proxy authentication user | | String
| *region* (common) | *Required* OBS service region. This is lower precedence
than endpoint based configuration | | String
-| *secretKey* (common) | *Required* Secret key for the cloud user | | String
-| *serviceKeys* (common) | Configuration object for cloud service
authentication | | ServiceKeys
| *bridgeErrorHandler* (consumer) | 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. | false |
boolean
+| *deleteAfterRead* (consumer) | Determines if objects should be deleted after
it has been retrieved | false | boolean
+| *delimiter* (consumer) | The character used for grouping object names | |
String
+| *destinationBucket* (consumer) | Name of destination bucket where objects
will be moved when moveAfterRead is set to true | | String
+| *fileName* (consumer) | Get the object from the bucket with the given file
name | | String
+| *includeFolders* (consumer) | If true, objects in folders will be consumed.
Otherwise, they will be ignored and no Exchanges will be created for them |
true | boolean
+| *maxMessagesPerPoll* (consumer) | The maximum number of messages to poll at
each polling | 10 | int
+| *moveAfterRead* (consumer) | Determines whether objects should be moved to a
different bucket after they have been retrieved. The destinationBucket option
must also be set for this option to work. | false | boolean
+| *prefix* (consumer) | The object name prefix used for filtering objects to
be listed | | String
+| *sendEmptyMessageWhenIdle* (consumer) | If the polling consumer did not poll
any files, you can enable this option to send an empty message (no body)
instead. | false | boolean
| *exceptionHandler* (consumer) | 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. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
+| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
+| *bucketLocation* (producer) | Location of bucket when creating a new bucket
| | String
| *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 [...]
+| *proxyHost* (proxy) | Proxy server ip/hostname | | String
+| *proxyPassword* (proxy) | Proxy authentication password | | String
+| *proxyPort* (proxy) | Proxy server port | | int
+| *proxyUser* (proxy) | Proxy authentication user | | String
+| *backoffErrorThreshold* (scheduler) | The number of subsequent error polls
(failed due some error) that should happen before the backoffMultipler should
kick-in. | | int
+| *backoffIdleThreshold* (scheduler) | The number of subsequent idle polls
that should happen before the backoffMultipler should kick-in. | | int
+| *backoffMultiplier* (scheduler) | To let the scheduled polling consumer
backoff if there has been a number of subsequent idles/errors in a row. The
multiplier is then the number of polls that will be skipped before the next
actual attempt is happening again. When this option is in use then
backoffIdleThreshold and/or backoffErrorThreshold must also be configured. | |
int
+| *delay* (scheduler) | Milliseconds before the next poll. | 500 | long
+| *greedy* (scheduler) | If greedy is enabled, then the ScheduledPollConsumer
will run immediately again, if the previous run polled 1 or more messages. |
false | boolean
+| *initialDelay* (scheduler) | Milliseconds before the first poll starts. |
1000 | long
+| *repeatCount* (scheduler) | Specifies a maximum limit of number of fires. So
if you set it to 1, the scheduler will only fire once. If you set it to 5, it
will only fire five times. A value of zero or negative means fire forever. | 0
| long
+| *runLoggingLevel* (scheduler) | The consumer logs a start/complete log line
when it polls. This option allows you to configure the logging level for that.
There are 6 enums and the value can be one of: TRACE, DEBUG, INFO, WARN, ERROR,
OFF | TRACE | LoggingLevel
+| *scheduledExecutorService* (scheduler) | Allows for configuring a
custom/shared thread pool to use for the consumer. By default each consumer has
its own single threaded thread pool. | | ScheduledExecutorService
+| *scheduler* (scheduler) | To use a cron scheduler from either camel-spring
or camel-quartz component. Use value spring or quartz for built in scheduler |
none | Object
+| *schedulerProperties* (scheduler) | To configure additional properties when
using a custom scheduler or any of the Quartz, Spring based scheduler. | | Map
+| *startScheduler* (scheduler) | Whether the scheduler should be auto started.
| true | boolean
+| *timeUnit* (scheduler) | Time unit for initialDelay and delay options. There
are 7 enums and the value can be one of: NANOSECONDS, MICROSECONDS,
MILLISECONDS, SECONDS, MINUTES, HOURS, DAYS | MILLISECONDS | TimeUnit
+| *useFixedDelay* (scheduler) | Controls if fixed delay or fixed rate is used.
See ScheduledExecutorService in JDK for details. | true | boolean
+| *authenticationKey* (security) | *Required* Authentication key for the cloud
user | | String
+| *ignoreSslVerification* (security) | Ignore SSL verification | false |
boolean
+| *secretKey* (security) | *Required* Secret key for the cloud user | | String
+| *serviceKeys* (security) | Configuration object for cloud service
authentication | | ServiceKeys
|===
// endpoint options: END
