This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 079cdc01946f8d8ebf2ece3b0931dbbe57e41325 Author: Raffaele Marcello <[email protected]> AuthorDate: Wed Feb 17 00:10:52 2021 +0100 CAMEL-15964 camel-google-storage comp. - class name collision with springboot --- .../catalog/docs/google-storage-component.adoc | 10 ++--- .../GoogleCloudStorageComponentConfigurer.java | 12 ++--- .../GoogleCloudStorageEndpointConfigurer.java | 4 +- .../component/google/storage/google-storage.json | 52 +++++++++++----------- .../src/main/docs/google-storage-component.adoc | 10 ++--- .../storage/GoogleCloudStorageComponent.java | 10 ++--- ...n.java => GoogleCloudStorageConfiguration.java} | 12 ++--- .../GoogleCloudStorageConnectionFactory.java | 2 +- .../google/storage/GoogleCloudStorageConsumer.java | 2 +- .../google/storage/GoogleCloudStorageEndpoint.java | 10 ++--- ...ions.java => GoogleCloudStorageOperations.java} | 2 +- .../google/storage/GoogleCloudStorageProducer.java | 10 ++--- ...ogleCloudStorageComponentConfigurationTest.java | 4 +- .../google/storage/unit/ProducerLocalTest.java | 14 +++--- .../dsl/GoogleStorageComponentBuilderFactory.java | 16 +++---- .../GoogleCloudStorageEndpointBuilderFactory.java | 10 ++--- .../ROOT/pages/google-storage-component.adoc | 10 ++--- 17 files changed, 95 insertions(+), 95 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-storage-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-storage-component.adoc index e63875f..ee5dec8 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-storage-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-storage-component.adoc @@ -86,7 +86,7 @@ The Google Storage component supports 16 options, which are listed below. |=== | Name | Description | Default | Type | *autoCreateBucket* (common) | Setting the autocreation of the bucket bucketName. | true | boolean -| *configuration* (common) | The component configuration | | GoogleCloudStorageComponentConfiguration +| *configuration* (common) | The component configuration | | GoogleCloudStorageConfiguration | *serviceAccountKey* (common) | Service account key to authenticate an application as a service account | | String | *storageClass* (common) | The Cloud Storage class to use when creating the new buckets | STANDARD | StorageClass | *storageClient* (common) | *Autowired* The storage client | | Storage @@ -99,7 +99,7 @@ The Google Storage component supports 16 options, which are listed below. | *moveAfterRead* (consumer) | Move objects from the origin bucket to a different bucket after they have been retrieved. To accomplish the operation the destinationBucket option must be set. The copy bucket operation is only performed if the Exchange is committed. If a rollback occurs, the object is not moved. | false | boolean | *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 [...] | *objectName* (producer) | The Object name inside the bucket | | String -| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageComponentOperations +| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageOperations | *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc. | true | boolean |=== // component options: END @@ -146,7 +146,7 @@ with the following path and query parameters: | *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 | *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 [...] | *objectName* (producer) | The Object name inside the bucket | | String -| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageComponentOperations +| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageOperations | *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 @@ -285,7 +285,7 @@ This operation will upload the file camel.txt with the content "Camel rocks!" in [source,java] -------------------------------------------------------------------------------- from("direct:start").process( exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.copyObject); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.copyObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "camel.txt" ); exchange.getIn().setHeader(GoogleCloudStorageConstants.DESTINATION_BUCKET_NAME, "myCamelBucket_dest"); exchange.getIn().setHeader(GoogleCloudStorageConstants.DESTINATION_OBJECT_NAME, "camel_copy.txt"); @@ -301,7 +301,7 @@ This operation will copy the object with the name expressed in the header DESTIN [source,java] -------------------------------------------------------------------------------- from("direct:start").process( exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.deleteObject); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.deleteObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "camel.txt" ); }) .to("google-storage://myCamelBucket?serviceAccountKey=/home/user/Downloads/my-key.json") diff --git a/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfigurer.java b/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfigurer.java index 0cba237..7eb4300 100644 --- a/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfigurer.java +++ b/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfigurer.java @@ -17,9 +17,9 @@ import org.apache.camel.support.component.PropertyConfigurerSupport; @SuppressWarnings("unchecked") public class GoogleCloudStorageComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter { - private org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration getOrCreateConfiguration(GoogleCloudStorageComponent target) { + private org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration getOrCreateConfiguration(GoogleCloudStorageComponent target) { if (target.getConfiguration() == null) { - target.setConfiguration(new org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration()); + target.setConfiguration(new org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration()); } return target.getConfiguration(); } @@ -34,7 +34,7 @@ public class GoogleCloudStorageComponentConfigurer extends PropertyConfigurerSup case "autowiredEnabled": target.setAutowiredEnabled(property(camelContext, boolean.class, value)); return true; case "bridgeerrorhandler": case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true; - case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration.class, value)); return true; + case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration.class, value)); return true; case "deleteafterread": case "deleteAfterRead": getOrCreateConfiguration(target).setDeleteAfterRead(property(camelContext, boolean.class, value)); return true; case "destinationbucket": @@ -49,7 +49,7 @@ public class GoogleCloudStorageComponentConfigurer extends PropertyConfigurerSup case "moveAfterRead": getOrCreateConfiguration(target).setMoveAfterRead(property(camelContext, boolean.class, value)); return true; case "objectname": case "objectName": getOrCreateConfiguration(target).setObjectName(property(camelContext, java.lang.String.class, value)); return true; - case "operation": getOrCreateConfiguration(target).setOperation(property(camelContext, org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations.class, value)); return true; + case "operation": getOrCreateConfiguration(target).setOperation(property(camelContext, org.apache.camel.component.google.storage.GoogleCloudStorageOperations.class, value)); return true; case "serviceaccountkey": case "serviceAccountKey": getOrCreateConfiguration(target).setServiceAccountKey(property(camelContext, java.lang.String.class, value)); return true; case "storageclass": @@ -76,7 +76,7 @@ public class GoogleCloudStorageComponentConfigurer extends PropertyConfigurerSup case "autowiredEnabled": return boolean.class; case "bridgeerrorhandler": case "bridgeErrorHandler": return boolean.class; - case "configuration": return org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration.class; + case "configuration": return org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration.class; case "deleteafterread": case "deleteAfterRead": return boolean.class; case "destinationbucket": @@ -91,7 +91,7 @@ public class GoogleCloudStorageComponentConfigurer extends PropertyConfigurerSup case "moveAfterRead": return boolean.class; case "objectname": case "objectName": return java.lang.String.class; - case "operation": return org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations.class; + case "operation": return org.apache.camel.component.google.storage.GoogleCloudStorageOperations.class; case "serviceaccountkey": case "serviceAccountKey": return java.lang.String.class; case "storageclass": diff --git a/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpointConfigurer.java b/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpointConfigurer.java index 53d4c0f..7fe7f5d 100644 --- a/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpointConfigurer.java +++ b/components/camel-google-storage/src/generated/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpointConfigurer.java @@ -53,7 +53,7 @@ public class GoogleCloudStorageEndpointConfigurer extends PropertyConfigurerSupp case "moveAfterRead": target.getConfiguration().setMoveAfterRead(property(camelContext, boolean.class, value)); return true; case "objectname": case "objectName": target.getConfiguration().setObjectName(property(camelContext, java.lang.String.class, value)); return true; - case "operation": target.getConfiguration().setOperation(property(camelContext, org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations.class, value)); return true; + case "operation": target.getConfiguration().setOperation(property(camelContext, org.apache.camel.component.google.storage.GoogleCloudStorageOperations.class, value)); return true; case "pollstrategy": case "pollStrategy": target.setPollStrategy(property(camelContext, org.apache.camel.spi.PollingConsumerPollStrategy.class, value)); return true; case "repeatcount": @@ -125,7 +125,7 @@ public class GoogleCloudStorageEndpointConfigurer extends PropertyConfigurerSupp case "moveAfterRead": return boolean.class; case "objectname": case "objectName": return java.lang.String.class; - case "operation": return org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations.class; + case "operation": return org.apache.camel.component.google.storage.GoogleCloudStorageOperations.class; case "pollstrategy": case "pollStrategy": return org.apache.camel.spi.PollingConsumerPollStrategy.class; case "repeatcount": diff --git a/components/camel-google-storage/src/generated/resources/org/apache/camel/component/google/storage/google-storage.json b/components/camel-google-storage/src/generated/resources/org/apache/camel/component/google/storage/google-storage.json index b5b787c..e34e885 100644 --- a/components/camel-google-storage/src/generated/resources/org/apache/camel/component/google/storage/google-storage.json +++ b/components/camel-google-storage/src/generated/resources/org/apache/camel/component/google/storage/google-storage.json @@ -22,43 +22,43 @@ "lenientProperties": false }, "componentProperties": { - "autoCreateBucket": { "kind": "property", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket bucketName." }, - "configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configuration" }, - "serviceAccountKey": { "kind": "property", "displayName": "Service Account Key", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Service account key to authenticate an application as a service account" }, - "storageClass": { "kind": "property", "displayName": "Storage Class", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.google.cloud.storage.StorageClass", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "STANDARD", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The Cloud Storage class to use when creat [...] - "storageClient": { "kind": "property", "displayName": "Storage Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "com.google.cloud.storage.Storage", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The storage client" }, - "storageLocation": { "kind": "property", "displayName": "Storage Location", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "US-EAST1", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The Cloud Storage location to use when creating the new [...] + "autoCreateBucket": { "kind": "property", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket bucketName." }, + "configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configuration" }, + "serviceAccountKey": { "kind": "property", "displayName": "Service Account Key", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Service account key to authenticate an application as a service account" }, + "storageClass": { "kind": "property", "displayName": "Storage Class", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.google.cloud.storage.StorageClass", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "STANDARD", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The Cloud Storage class to use when creating the n [...] + "storageClient": { "kind": "property", "displayName": "Storage Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "com.google.cloud.storage.Storage", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The storage client" }, + "storageLocation": { "kind": "property", "displayName": "Storage Location", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "US-EAST1", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The Cloud Storage location to use when creating the new buckets" }, "bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a me [...] - "deleteAfterRead": { "kind": "property", "displayName": "Delete After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Delete objects from the bucket after they have been retrieved. Th [...] - "destinationBucket": { "kind": "property", "displayName": "Destination Bucket", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Define the destination bucket where an object must be moved when moveAfterRe [...] - "includeBody": { "kind": "property", "displayName": "Include Body", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "If it is true, the Object exchange will be consumed and put into the body. [...] - "includeFolders": { "kind": "property", "displayName": "Include Folders", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "If it is true, the folders\/directories will be consumed. If it is f [...] - "moveAfterRead": { "kind": "property", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Move objects from the origin bucket to a different bucket after they [...] + "deleteAfterRead": { "kind": "property", "displayName": "Delete After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Delete objects from the bucket after they have been retrieved. The delete [...] + "destinationBucket": { "kind": "property", "displayName": "Destination Bucket", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Define the destination bucket where an object must be moved when moveAfterRead is set [...] + "includeBody": { "kind": "property", "displayName": "Include Body", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "If it is true, the Object exchange will be consumed and put into the body. If false [...] + "includeFolders": { "kind": "property", "displayName": "Include Folders", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "If it is true, the folders\/directories will be consumed. If it is false, the [...] + "moveAfterRead": { "kind": "property", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Move objects from the origin bucket to a different bucket after they have bee [...] "lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during star [...] - "objectName": { "kind": "property", "displayName": "Object Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The Object name inside the bucket" }, - "operation": { "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations", "enum": [ "copyObject", "listObjects", "deleteObject", "deleteBucket", "listBuckets", "getObject", "createDownloadLink" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.Googl [...] + "objectName": { "kind": "property", "displayName": "Object Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The Object name inside the bucket" }, + "operation": { "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.google.storage.GoogleCloudStorageOperations", "enum": [ "copyObject", "listObjects", "deleteObject", "deleteBucket", "listBuckets", "getObject", "createDownloadLink" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudSto [...] "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...] }, "properties": { - "bucketName": { "kind": "path", "displayName": "Bucket Name", "group": "common", "label": "common", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Bucket name or ARN" }, - "autoCreateBucket": { "kind": "parameter", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket bucketName." }, - "serviceAccountKey": { "kind": "parameter", "displayName": "Service Account Key", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Service account key to authenticate an application as a service account" }, - "storageClass": { "kind": "parameter", "displayName": "Storage Class", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.google.cloud.storage.StorageClass", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "STANDARD", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The Cloud Storage class to use when crea [...] - "storageClient": { "kind": "parameter", "displayName": "Storage Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "com.google.cloud.storage.Storage", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The storage client" }, - "storageLocation": { "kind": "parameter", "displayName": "Storage Location", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "US-EAST1", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The Cloud Storage location to use when creating the new [...] + "bucketName": { "kind": "path", "displayName": "Bucket Name", "group": "common", "label": "common", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Bucket name or ARN" }, + "autoCreateBucket": { "kind": "parameter", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket bucketName." }, + "serviceAccountKey": { "kind": "parameter", "displayName": "Service Account Key", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Service account key to authenticate an application as a service account" }, + "storageClass": { "kind": "parameter", "displayName": "Storage Class", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "com.google.cloud.storage.StorageClass", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "STANDARD", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The Cloud Storage class to use when creating the [...] + "storageClient": { "kind": "parameter", "displayName": "Storage Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "com.google.cloud.storage.Storage", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The storage client" }, + "storageLocation": { "kind": "parameter", "displayName": "Storage Location", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "US-EAST1", "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The Cloud Storage location to use when creating the new buckets" }, "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, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Delete objects from the bucket after they have been retrieved. T [...] - "destinationBucket": { "kind": "parameter", "displayName": "Destination Bucket", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Define the destination bucket where an object must be moved when moveAfterR [...] - "includeBody": { "kind": "parameter", "displayName": "Include Body", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "If it is true, the Object exchange will be consumed and put into the body [...] - "includeFolders": { "kind": "parameter", "displayName": "Include Folders", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "If it is true, the folders\/directories will be consumed. If it is [...] - "moveAfterRead": { "kind": "parameter", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "Move objects from the origin bucket to a different bucket after the [...] + "deleteAfterRead": { "kind": "parameter", "displayName": "Delete After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Delete objects from the bucket after they have been retrieved. The delete [...] + "destinationBucket": { "kind": "parameter", "displayName": "Destination Bucket", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Define the destination bucket where an object must be moved when moveAfterRead is se [...] + "includeBody": { "kind": "parameter", "displayName": "Include Body", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "If it is true, the Object exchange will be consumed and put into the body. If fals [...] + "includeFolders": { "kind": "parameter", "displayName": "Include Folders", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "If it is true, the folders\/directories will be consumed. If it is false, th [...] + "moveAfterRead": { "kind": "parameter", "displayName": "Move After Read", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "Move objects from the origin bucket to a different bucket after they have be [...] "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." }, "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 [...] "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 [...] - "objectName": { "kind": "parameter", "displayName": "Object Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration", "configurationField": "configuration", "description": "The Object name inside the bucket" }, - "operation": { "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations", "enum": [ "copyObject", "listObjects", "deleteObject", "deleteBucket", "listBuckets", "getObject", "createDownloadLink" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.Goog [...] + "objectName": { "kind": "parameter", "displayName": "Object Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration", "configurationField": "configuration", "description": "The Object name inside the bucket" }, + "operation": { "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.google.storage.GoogleCloudStorageOperations", "enum": [ "copyObject", "listObjects", "deleteObject", "deleteBucket", "listBuckets", "getObject", "createDownloadLink" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.google.storage.GoogleCloudSt [...] "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 [...] diff --git a/components/camel-google-storage/src/main/docs/google-storage-component.adoc b/components/camel-google-storage/src/main/docs/google-storage-component.adoc index e63875f..ee5dec8 100644 --- a/components/camel-google-storage/src/main/docs/google-storage-component.adoc +++ b/components/camel-google-storage/src/main/docs/google-storage-component.adoc @@ -86,7 +86,7 @@ The Google Storage component supports 16 options, which are listed below. |=== | Name | Description | Default | Type | *autoCreateBucket* (common) | Setting the autocreation of the bucket bucketName. | true | boolean -| *configuration* (common) | The component configuration | | GoogleCloudStorageComponentConfiguration +| *configuration* (common) | The component configuration | | GoogleCloudStorageConfiguration | *serviceAccountKey* (common) | Service account key to authenticate an application as a service account | | String | *storageClass* (common) | The Cloud Storage class to use when creating the new buckets | STANDARD | StorageClass | *storageClient* (common) | *Autowired* The storage client | | Storage @@ -99,7 +99,7 @@ The Google Storage component supports 16 options, which are listed below. | *moveAfterRead* (consumer) | Move objects from the origin bucket to a different bucket after they have been retrieved. To accomplish the operation the destinationBucket option must be set. The copy bucket operation is only performed if the Exchange is committed. If a rollback occurs, the object is not moved. | false | boolean | *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 [...] | *objectName* (producer) | The Object name inside the bucket | | String -| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageComponentOperations +| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageOperations | *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc. | true | boolean |=== // component options: END @@ -146,7 +146,7 @@ with the following path and query parameters: | *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 | *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 [...] | *objectName* (producer) | The Object name inside the bucket | | String -| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageComponentOperations +| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageOperations | *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 @@ -285,7 +285,7 @@ This operation will upload the file camel.txt with the content "Camel rocks!" in [source,java] -------------------------------------------------------------------------------- from("direct:start").process( exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.copyObject); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.copyObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "camel.txt" ); exchange.getIn().setHeader(GoogleCloudStorageConstants.DESTINATION_BUCKET_NAME, "myCamelBucket_dest"); exchange.getIn().setHeader(GoogleCloudStorageConstants.DESTINATION_OBJECT_NAME, "camel_copy.txt"); @@ -301,7 +301,7 @@ This operation will copy the object with the name expressed in the header DESTIN [source,java] -------------------------------------------------------------------------------- from("direct:start").process( exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.deleteObject); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.deleteObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "camel.txt" ); }) .to("google-storage://myCamelBucket?serviceAccountKey=/home/user/Downloads/my-key.json") diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponent.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponent.java index f53a171..c42e29d 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponent.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponent.java @@ -28,7 +28,7 @@ import org.apache.camel.support.DefaultComponent; public class GoogleCloudStorageComponent extends DefaultComponent { @Metadata - private GoogleCloudStorageComponentConfiguration configuration = new GoogleCloudStorageComponentConfiguration(); + private GoogleCloudStorageConfiguration configuration = new GoogleCloudStorageConfiguration(); public GoogleCloudStorageComponent() { this(null); @@ -46,8 +46,8 @@ public class GoogleCloudStorageComponent extends DefaultComponent { if (remaining.startsWith("arn:")) { remaining = remaining.substring(remaining.lastIndexOf(':') + 1, remaining.length()); } - final GoogleCloudStorageComponentConfiguration configuration - = this.configuration != null ? this.configuration.copy() : new GoogleCloudStorageComponentConfiguration(); + final GoogleCloudStorageConfiguration configuration + = this.configuration != null ? this.configuration.copy() : new GoogleCloudStorageConfiguration(); setProperties(configuration, parameters); configuration.setBucketName(remaining); Endpoint endpoint = new GoogleCloudStorageEndpoint(uri, this, configuration); @@ -55,14 +55,14 @@ public class GoogleCloudStorageComponent extends DefaultComponent { return endpoint; } - public GoogleCloudStorageComponentConfiguration getConfiguration() { + public GoogleCloudStorageConfiguration getConfiguration() { return configuration; } /** * The component configuration */ - public void setConfiguration(GoogleCloudStorageComponentConfiguration configuration) { + public void setConfiguration(GoogleCloudStorageConfiguration configuration) { this.configuration = configuration; } diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfiguration.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConfiguration.java similarity index 94% rename from components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfiguration.java rename to components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConfiguration.java index 288dec4..035240e 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentConfiguration.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConfiguration.java @@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParams; import org.apache.camel.spi.UriPath; @UriParams -public class GoogleCloudStorageComponentConfiguration implements Cloneable { +public class GoogleCloudStorageConfiguration implements Cloneable { @UriPath(label = "common", description = "Bucket name or ARN") @Metadata(required = true) @@ -36,7 +36,7 @@ public class GoogleCloudStorageComponentConfiguration implements Cloneable { @UriParam(label = "producer", enums = "copyObject,listObjects,deleteObject,deleteBucket,listBuckets,getObject,createDownloadLink") - private GoogleCloudStorageComponentOperations operation; + private GoogleCloudStorageOperations operation; @UriParam(label = "producer", description = "The Object name inside the bucket") private String objectName; @@ -144,7 +144,7 @@ public class GoogleCloudStorageComponentConfiguration implements Cloneable { this.storageClient = storageClient; } - public GoogleCloudStorageComponentOperations getOperation() { + public GoogleCloudStorageOperations getOperation() { return operation; } @@ -153,7 +153,7 @@ public class GoogleCloudStorageComponentConfiguration implements Cloneable { * * @param operation */ - public void setOperation(GoogleCloudStorageComponentOperations operation) { + public void setOperation(GoogleCloudStorageOperations operation) { this.operation = operation; } @@ -230,9 +230,9 @@ public class GoogleCloudStorageComponentConfiguration implements Cloneable { return includeBody; } - public GoogleCloudStorageComponentConfiguration copy() { + public GoogleCloudStorageConfiguration copy() { try { - return (GoogleCloudStorageComponentConfiguration) super.clone(); + return (GoogleCloudStorageConfiguration) super.clone(); } catch (CloneNotSupportedException e) { throw new RuntimeCamelException(e); } diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConnectionFactory.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConnectionFactory.java index 60f8899..627f4d5 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConnectionFactory.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConnectionFactory.java @@ -31,7 +31,7 @@ public final class GoogleCloudStorageConnectionFactory { private GoogleCloudStorageConnectionFactory() { } - public static Storage create(GoogleCloudStorageComponentConfiguration configuration) throws Exception { + public static Storage create(GoogleCloudStorageConfiguration configuration) throws Exception { if (!Strings.isNullOrEmpty(configuration.getServiceAccountKey())) { Storage storage = StorageOptions.newBuilder() .setCredentials( diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConsumer.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConsumer.java index bbe41b0..1a03c26 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConsumer.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageConsumer.java @@ -241,7 +241,7 @@ public class GoogleCloudStorageConsumer extends ScheduledBatchPollingConsumer { } } - protected GoogleCloudStorageComponentConfiguration getConfiguration() { + protected GoogleCloudStorageConfiguration getConfiguration() { return getEndpoint().getConfiguration(); } diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpoint.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpoint.java index e0a4b17..ba4b69c 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpoint.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageEndpoint.java @@ -54,12 +54,12 @@ public class GoogleCloudStorageEndpoint extends ScheduledPollEndpoint { private static final Logger LOG = LoggerFactory.getLogger(GoogleCloudStorageEndpoint.class); @UriParam - private GoogleCloudStorageComponentConfiguration configuration; + private GoogleCloudStorageConfiguration configuration; private Storage storageClient; public GoogleCloudStorageEndpoint(String uri, GoogleCloudStorageComponent component, - GoogleCloudStorageComponentConfiguration configuration) { + GoogleCloudStorageConfiguration configuration) { super(uri, component); this.configuration = configuration; } @@ -104,7 +104,7 @@ public class GoogleCloudStorageEndpoint extends ScheduledPollEndpoint { } } - public static Bucket createNewBucket(String bucketName, GoogleCloudStorageComponentConfiguration conf, Storage storage) { + public static Bucket createNewBucket(String bucketName, GoogleCloudStorageConfiguration conf, Storage storage) { final String location = conf.getStorageLocation(); final StorageClass storageClass = conf.getStorageClass(); @@ -117,7 +117,7 @@ public class GoogleCloudStorageEndpoint extends ScheduledPollEndpoint { return bucket; } - public GoogleCloudStorageComponentConfiguration getConfiguration() { + public GoogleCloudStorageConfiguration getConfiguration() { return configuration; } @@ -126,7 +126,7 @@ public class GoogleCloudStorageEndpoint extends ScheduledPollEndpoint { * * @param configuration */ - public void setConfiguration(GoogleCloudStorageComponentConfiguration configuration) { + public void setConfiguration(GoogleCloudStorageConfiguration configuration) { this.configuration = configuration; } diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentOperations.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageOperations.java similarity index 94% rename from components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentOperations.java rename to components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageOperations.java index 2415b6b..4e87340 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageComponentOperations.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageOperations.java @@ -16,7 +16,7 @@ */ package org.apache.camel.component.google.storage; -public enum GoogleCloudStorageComponentOperations { +public enum GoogleCloudStorageOperations { copyObject, listObjects, deleteObject, diff --git a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageProducer.java b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageProducer.java index af4d477..fbce312 100644 --- a/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageProducer.java +++ b/components/camel-google-storage/src/main/java/org/apache/camel/component/google/storage/GoogleCloudStorageProducer.java @@ -61,7 +61,7 @@ public class GoogleCloudStorageProducer extends DefaultProducer { public void process(Exchange exchange) throws Exception { - GoogleCloudStorageComponentOperations operation = determineOperation(exchange); + GoogleCloudStorageOperations operation = determineOperation(exchange); if (ObjectHelper.isEmpty(operation)) { processFile(getEndpoint().getStorageClient(), exchange); } else { @@ -344,10 +344,10 @@ public class GoogleCloudStorageProducer extends DefaultProducer { return exchange.getMessage(); } - private GoogleCloudStorageComponentOperations determineOperation(Exchange exchange) { - GoogleCloudStorageComponentOperations operation = exchange.getIn().getHeader( + private GoogleCloudStorageOperations determineOperation(Exchange exchange) { + GoogleCloudStorageOperations operation = exchange.getIn().getHeader( GoogleCloudStorageConstants.OPERATION, - GoogleCloudStorageComponentOperations.class); + GoogleCloudStorageOperations.class); if (operation == null) { operation = getConfiguration().getOperation(); } @@ -359,7 +359,7 @@ public class GoogleCloudStorageProducer extends DefaultProducer { return (GoogleCloudStorageEndpoint) super.getEndpoint(); } - private GoogleCloudStorageComponentConfiguration getConfiguration() { + private GoogleCloudStorageConfiguration getConfiguration() { return this.endpoint.getConfiguration(); } diff --git a/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/GoogleCloudStorageComponentConfigurationTest.java b/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/GoogleCloudStorageComponentConfigurationTest.java index d133208..8fe7c1e 100644 --- a/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/GoogleCloudStorageComponentConfigurationTest.java +++ b/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/GoogleCloudStorageComponentConfigurationTest.java @@ -17,7 +17,7 @@ package org.apache.camel.component.google.storage.unit; import org.apache.camel.component.google.storage.GoogleCloudStorageComponent; -import org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration; +import org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration; import org.apache.camel.component.google.storage.GoogleCloudStorageEndpoint; import org.apache.camel.test.junit5.CamelTestSupport; import org.junit.jupiter.api.Test; @@ -56,7 +56,7 @@ public class GoogleCloudStorageComponentConfigurationTest extends CamelTestSuppo bucketName, serviceAccountKeyFile, moveAfterRead, destinationBucket, autoCreateBucket, deleteAfterRead, includeBody)); - GoogleCloudStorageComponentConfiguration configuration = endpoint.getConfiguration(); + GoogleCloudStorageConfiguration configuration = endpoint.getConfiguration(); assertEquals(configuration.getBucketName(), bucketName); assertEquals(configuration.getServiceAccountKey(), serviceAccountKeyFile); assertEquals(configuration.isMoveAfterRead(), moveAfterRead); diff --git a/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/ProducerLocalTest.java b/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/ProducerLocalTest.java index 41bb2fe..5dc9b02 100644 --- a/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/ProducerLocalTest.java +++ b/components/camel-google-storage/src/test/java/org/apache/camel/component/google/storage/unit/ProducerLocalTest.java @@ -25,8 +25,8 @@ import org.apache.camel.EndpointInject; import org.apache.camel.Exchange; import org.apache.camel.ProducerTemplate; import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations; import org.apache.camel.component.google.storage.GoogleCloudStorageConstants; +import org.apache.camel.component.google.storage.GoogleCloudStorageOperations; import org.apache.camel.component.mock.MockEndpoint; import org.junit.jupiter.api.Test; import org.slf4j.Logger; @@ -86,7 +86,7 @@ public class ProducerLocalTest extends GoogleCloudStorageBaseTest { Exchange listBucketsExchange = template.request("direct:listBucket", exchange -> { exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, - GoogleCloudStorageComponentOperations.listBuckets); + GoogleCloudStorageOperations.listBuckets); }); List<Bucket> bucketsList = listBucketsExchange.getMessage().getBody(List.class); LOG.info("bucketsList {}", bucketsList); @@ -94,7 +94,7 @@ public class ProducerLocalTest extends GoogleCloudStorageBaseTest { Exchange listObjectsExchange = template.request("direct:listObjects", exchange -> { exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, - GoogleCloudStorageComponentOperations.listObjects); + GoogleCloudStorageOperations.listObjects); }); LOG.info("listObjectsExchange.body={}", listObjectsExchange.getMessage().getBody()); List<Blob> resp = listObjectsExchange.getMessage().getBody(List.class); @@ -103,7 +103,7 @@ public class ProducerLocalTest extends GoogleCloudStorageBaseTest { Exchange getObjectExchange = template.request("direct:getObject", exchange -> { exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, - GoogleCloudStorageComponentOperations.getObject); + GoogleCloudStorageOperations.getObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, fileName); }); Blob getObject = getObjectExchange.getMessage().getBody(Blob.class); @@ -114,7 +114,7 @@ public class ProducerLocalTest extends GoogleCloudStorageBaseTest { /* //sign url Exchange downloadLinkExchange = template.request( "direct:downloadLink", exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.createDownloadLink); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.createDownloadLink); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "readme.txt" ); exchange.getIn().setHeader(GoogleCloudStorageConstants.DOWNLOAD_LINK_EXPIRATION_TIME, 86400000L); //1 day }); @@ -125,7 +125,7 @@ public class ProducerLocalTest extends GoogleCloudStorageBaseTest { Exchange deleteObjectExchange = template.send("direct:deleteObject", exchange -> { exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, - GoogleCloudStorageComponentOperations.deleteObject); + GoogleCloudStorageOperations.deleteObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, fileName); }); @@ -135,7 +135,7 @@ public class ProducerLocalTest extends GoogleCloudStorageBaseTest { Exchange deleteBucketExchange = template.send("direct:deleteBucket", exchange -> { exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, - GoogleCloudStorageComponentOperations.deleteBucket); + GoogleCloudStorageOperations.deleteBucket); }); boolean deleteBucket = deleteBucketExchange.getMessage().getBody(Boolean.class).booleanValue(); LOG.info("deleteBucket {}", deleteBucket); diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoogleStorageComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoogleStorageComponentBuilderFactory.java index 47b4229..231abe2 100644 --- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoogleStorageComponentBuilderFactory.java +++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoogleStorageComponentBuilderFactory.java @@ -72,7 +72,7 @@ public interface GoogleStorageComponentBuilderFactory { * The component configuration. * * The option is a: - * <code>org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration</code> type. + * <code>org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration</code> type. * * Group: common * @@ -80,7 +80,7 @@ public interface GoogleStorageComponentBuilderFactory { * @return the dsl builder */ default GoogleStorageComponentBuilder configuration( - org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration configuration) { + org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration configuration) { doSetProperty("configuration", configuration); return this; } @@ -304,7 +304,7 @@ public interface GoogleStorageComponentBuilderFactory { * Set the operation for the producer. * * The option is a: - * <code>org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations</code> type. + * <code>org.apache.camel.component.google.storage.GoogleCloudStorageOperations</code> type. * * Group: producer * @@ -312,7 +312,7 @@ public interface GoogleStorageComponentBuilderFactory { * @return the dsl builder */ default GoogleStorageComponentBuilder operation( - org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations operation) { + org.apache.camel.component.google.storage.GoogleCloudStorageOperations operation) { doSetProperty("operation", operation); return this; } @@ -348,10 +348,10 @@ public interface GoogleStorageComponentBuilderFactory { protected GoogleCloudStorageComponent buildConcreteComponent() { return new GoogleCloudStorageComponent(); } - private org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration getOrCreateConfiguration( + private org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration getOrCreateConfiguration( org.apache.camel.component.google.storage.GoogleCloudStorageComponent component) { if (component.getConfiguration() == null) { - component.setConfiguration(new org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration()); + component.setConfiguration(new org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration()); } return component.getConfiguration(); } @@ -362,7 +362,7 @@ public interface GoogleStorageComponentBuilderFactory { Object value) { switch (name) { case "autoCreateBucket": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setAutoCreateBucket((boolean) value); return true; - case "configuration": ((GoogleCloudStorageComponent) component).setConfiguration((org.apache.camel.component.google.storage.GoogleCloudStorageComponentConfiguration) value); return true; + case "configuration": ((GoogleCloudStorageComponent) component).setConfiguration((org.apache.camel.component.google.storage.GoogleCloudStorageConfiguration) value); return true; case "serviceAccountKey": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setServiceAccountKey((java.lang.String) value); return true; case "storageClass": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setStorageClass((com.google.cloud.storage.StorageClass) value); return true; case "storageClient": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setStorageClient((com.google.cloud.storage.Storage) value); return true; @@ -375,7 +375,7 @@ public interface GoogleStorageComponentBuilderFactory { case "moveAfterRead": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setMoveAfterRead((boolean) value); return true; case "lazyStartProducer": ((GoogleCloudStorageComponent) component).setLazyStartProducer((boolean) value); return true; case "objectName": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setObjectName((java.lang.String) value); return true; - case "operation": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setOperation((org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations) value); return true; + case "operation": getOrCreateConfiguration((GoogleCloudStorageComponent) component).setOperation((org.apache.camel.component.google.storage.GoogleCloudStorageOperations) value); return true; case "autowiredEnabled": ((GoogleCloudStorageComponent) component).setAutowiredEnabled((boolean) value); return true; default: return false; } diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoogleCloudStorageEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoogleCloudStorageEndpointBuilderFactory.java index 1520a1a..235c0e7 100644 --- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoogleCloudStorageEndpointBuilderFactory.java +++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoogleCloudStorageEndpointBuilderFactory.java @@ -1243,7 +1243,7 @@ public interface GoogleCloudStorageEndpointBuilderFactory { * Set the operation for the producer. * * The option is a: - * <code>org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations</code> type. + * <code>org.apache.camel.component.google.storage.GoogleCloudStorageOperations</code> type. * * Group: producer * @@ -1251,7 +1251,7 @@ public interface GoogleCloudStorageEndpointBuilderFactory { * @return the dsl builder */ default GoogleCloudStorageEndpointProducerBuilder operation( - GoogleCloudStorageComponentOperations operation) { + GoogleCloudStorageOperations operation) { doSetProperty("operation", operation); return this; } @@ -1259,7 +1259,7 @@ public interface GoogleCloudStorageEndpointBuilderFactory { * Set the operation for the producer. * * The option will be converted to a - * <code>org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations</code> type. + * <code>org.apache.camel.component.google.storage.GoogleCloudStorageOperations</code> type. * * Group: producer * @@ -1441,9 +1441,9 @@ public interface GoogleCloudStorageEndpointBuilderFactory { /** * Proxy enum for - * <code>org.apache.camel.component.google.storage.GoogleCloudStorageComponentOperations</code> enum. + * <code>org.apache.camel.component.google.storage.GoogleCloudStorageOperations</code> enum. */ - enum GoogleCloudStorageComponentOperations { + enum GoogleCloudStorageOperations { copyObject, listObjects, deleteObject, diff --git a/docs/components/modules/ROOT/pages/google-storage-component.adoc b/docs/components/modules/ROOT/pages/google-storage-component.adoc index f8348c6..9ee40df 100644 --- a/docs/components/modules/ROOT/pages/google-storage-component.adoc +++ b/docs/components/modules/ROOT/pages/google-storage-component.adoc @@ -88,7 +88,7 @@ The Google Storage component supports 16 options, which are listed below. |=== | Name | Description | Default | Type | *autoCreateBucket* (common) | Setting the autocreation of the bucket bucketName. | true | boolean -| *configuration* (common) | The component configuration | | GoogleCloudStorageComponentConfiguration +| *configuration* (common) | The component configuration | | GoogleCloudStorageConfiguration | *serviceAccountKey* (common) | Service account key to authenticate an application as a service account | | String | *storageClass* (common) | The Cloud Storage class to use when creating the new buckets | STANDARD | StorageClass | *storageClient* (common) | *Autowired* The storage client | | Storage @@ -101,7 +101,7 @@ The Google Storage component supports 16 options, which are listed below. | *moveAfterRead* (consumer) | Move objects from the origin bucket to a different bucket after they have been retrieved. To accomplish the operation the destinationBucket option must be set. The copy bucket operation is only performed if the Exchange is committed. If a rollback occurs, the object is not moved. | false | boolean | *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 [...] | *objectName* (producer) | The Object name inside the bucket | | String -| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageComponentOperations +| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageOperations | *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc. | true | boolean |=== // component options: END @@ -148,7 +148,7 @@ with the following path and query parameters: | *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 | *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 [...] | *objectName* (producer) | The Object name inside the bucket | | String -| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageComponentOperations +| *operation* (producer) | Set the operation for the producer. There are 7 enums and the value can be one of: copyObject, listObjects, deleteObject, deleteBucket, listBuckets, getObject, createDownloadLink | | GoogleCloudStorageOperations | *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 @@ -287,7 +287,7 @@ This operation will upload the file camel.txt with the content "Camel rocks!" in [source,java] -------------------------------------------------------------------------------- from("direct:start").process( exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.copyObject); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.copyObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "camel.txt" ); exchange.getIn().setHeader(GoogleCloudStorageConstants.DESTINATION_BUCKET_NAME, "myCamelBucket_dest"); exchange.getIn().setHeader(GoogleCloudStorageConstants.DESTINATION_OBJECT_NAME, "camel_copy.txt"); @@ -303,7 +303,7 @@ This operation will copy the object with the name expressed in the header DESTIN [source,java] -------------------------------------------------------------------------------- from("direct:start").process( exchange -> { - exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageComponentOperations.deleteObject); + exchange.getIn().setHeader(GoogleCloudStorageConstants.OPERATION, GoogleCloudStorageOperations.deleteObject); exchange.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "camel.txt" ); }) .to("google-storage://myCamelBucket?serviceAccountKey=/home/user/Downloads/my-key.json")
