Repository: camel Updated Branches: refs/heads/master 0704f7e61 -> bd55ef8b3
CAMEL-8920 Camel-JClouds: Add new operations to Blobstore component, add clearContainer operation Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5439702d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5439702d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5439702d Branch: refs/heads/master Commit: 5439702d0a7de2e9bd5f6a6241cd16f1f349ae9d Parents: 0704f7e Author: Andrea Cosentino <anco...@gmail.com> Authored: Tue Jun 30 17:26:59 2015 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Tue Jun 30 17:26:59 2015 +0200 ---------------------------------------------------------------------- .../camel/component/jclouds/JcloudsBlobStoreHelper.java | 9 ++++++++- .../camel/component/jclouds/JcloudsBlobStoreProducer.java | 4 +++- .../apache/camel/component/jclouds/JcloudsConstants.java | 1 + 3 files changed, 12 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/5439702d/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java ---------------------------------------------------------------------- diff --git a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java index 27fcec9..25f0a41 100644 --- a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java +++ b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java @@ -107,11 +107,18 @@ public final class JcloudsBlobStoreHelper { /** - * Reads from a {@link BlobStore}. It returns an Object. + * Remove a specific blob from a {@link BlobStore} */ public static void removeBlob(BlobStore blobStore, String container, String blobName) throws IOException { if (!Strings.isNullOrEmpty(blobName)) { blobStore.removeBlob(container, blobName); } } + + /** + * Clear a {@link BlobStore} specific container + */ + public static void clearContainer(BlobStore blobStore, String container) throws IOException { + blobStore.clearContainer(container); + } } http://git-wip-us.apache.org/repos/asf/camel/blob/5439702d/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducer.java b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducer.java index 4ab5ddc..763531e 100644 --- a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducer.java +++ b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducer.java @@ -57,8 +57,10 @@ public class JcloudsBlobStoreProducer extends JcloudsProducer { exchange.getOut().setBody(JcloudsBlobStoreHelper.readBlob(blobStore, container, blobName)); } else if (JcloudsConstants.COUNT_BLOBS.equals(operation)) { exchange.getOut().setBody(JcloudsBlobStoreHelper.countBlob(blobStore, container)); - } else if (JcloudsConstants.REMOVE_BLOB.equals(operation)) { + } else if (JcloudsConstants.REMOVE_BLOB.equals(operation)) { JcloudsBlobStoreHelper.removeBlob(blobStore, container, blobName); + } else if (JcloudsConstants.CLEAR_CONTAINER.equals(operation)) { + JcloudsBlobStoreHelper.clearContainer(blobStore, container); } else { Payload body = exchange.getIn().getBody(Payload.class); JcloudsBlobStoreHelper.writeBlob(blobStore, container, blobName, body); http://git-wip-us.apache.org/repos/asf/camel/blob/5439702d/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsConstants.java ---------------------------------------------------------------------- diff --git a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsConstants.java b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsConstants.java index 6b60a03..3d2d90e 100644 --- a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsConstants.java +++ b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsConstants.java @@ -30,6 +30,7 @@ public final class JcloudsConstants { public static final String GET = "CamelJcloudsGet"; public static final String COUNT_BLOBS = "CamelJcloudsCountBlobs"; public static final String REMOVE_BLOB = "CamelJcloudsRemoveBlob"; + public static final String CLEAR_CONTAINER = "CamelJcloudsClearContainer"; public static final String LIST_IMAGES = "CamelJcloudsListImages"; public static final String LIST_HARDWARE = "CamelJcloudsListHardware"; public static final String LIST_NODES = "CamelJcloudsListNodes";
