CAMEL-8918 Camel-Jclouds: Add countBlobs and removeBlob operation to Blobstore component, add countBlobs test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2f311215 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2f311215 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2f311215 Branch: refs/heads/master Commit: 2f3112155ddbba237cc9830b949c12d3eaab71de Parents: 4a0c0f8 Author: Andrea Cosentino <anco...@gmail.com> Authored: Mon Jun 29 13:46:56 2015 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Mon Jun 29 14:24:54 2015 +0200 ---------------------------------------------------------------------- .../jclouds/JcloudsBlobStoreProducerTest.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/2f311215/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducerTest.java b/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducerTest.java index 7fa8d75..ab949a2 100644 --- a/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducerTest.java +++ b/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsBlobStoreProducerTest.java @@ -17,10 +17,14 @@ package org.apache.camel.component.jclouds; import java.io.ByteArrayInputStream; + import javax.xml.transform.TransformerException; import javax.xml.transform.sax.SAXSource; + import org.xml.sax.InputSource; + import com.google.common.collect.Lists; + import org.apache.camel.Exchange; import org.apache.camel.StreamCache; import org.apache.camel.builder.RouteBuilder; @@ -67,6 +71,14 @@ public class JcloudsBlobStoreProducerTest extends CamelTestSupport { Object result = template.requestBodyAndHeader("direct:put-and-get", null, JcloudsConstants.OPERATION, JcloudsConstants.GET, String.class); assertEquals(MESSAGE, result); } + + @Test + public void testBlobStorePutAndCount() throws InterruptedException { + String message = "Some message"; + template.sendBody("direct:put-and-count", message); + Object result = template.requestBodyAndHeader("direct:put-and-count", null, JcloudsConstants.OPERATION, JcloudsConstants.COUNT_BLOBS, Long.class); + assertEquals(new Long(1), result); + } @Override protected RouteBuilder createRouteBuilder() throws Exception { @@ -84,6 +96,11 @@ public class JcloudsBlobStoreProducerTest extends CamelTestSupport { .setHeader(JcloudsConstants.BLOB_NAME, constant(TEST_BLOB_IN_DIR)) .setHeader(JcloudsConstants.CONTAINER_NAME, constant(TEST_CONTAINER)) .to("jclouds:blobstore:transient"); + + from("direct:put-and-count") + .setHeader(JcloudsConstants.BLOB_NAME, constant(TEST_BLOB_IN_DIR)) + .setHeader(JcloudsConstants.CONTAINER_NAME, constant(TEST_CONTAINER)) + .to("jclouds:blobstore:transient"); } }; }
