You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2015/06/30 17:29:04 UTC
[2/9] camel git commit: CAMEL-8920 Camel-JClouds: Add new operations
to Blobstore component, add clearContainer tests
CAMEL-8920 Camel-JClouds: Add new operations to Blobstore component, add clearContainer tests
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5bad8c08
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5bad8c08
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5bad8c08
Branch: refs/heads/master
Commit: 5bad8c08440a8ce84b6b6daec3be67e40843b178
Parents: 5439702
Author: Andrea Cosentino <an...@gmail.com>
Authored: Tue Jun 30 17:27:09 2015 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Tue Jun 30 17:27:09 2015 +0200
----------------------------------------------------------------------
.../jclouds/JcloudsBlobStoreProducerTest.java | 16 ++++++++++++++++
.../jclouds/JcloudsSpringBlobstoreTest.java | 6 ++++++
.../src/test/resources/blobstore-test.xml | 7 +++++++
3 files changed, 29 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/5bad8c08/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 7af8ff3..75aa0ab 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
@@ -88,6 +88,17 @@ public class JcloudsBlobStoreProducerTest extends CamelTestSupport {
Object result = template.requestBodyAndHeader("direct:put-and-remove", null, JcloudsConstants.OPERATION, JcloudsConstants.COUNT_BLOBS, Long.class);
assertEquals(new Long(0), result);
}
+
+ @Test
+ public void testBlobStorePutAndClear() throws InterruptedException {
+ String message = "Some message";
+ template.sendBody("direct:put-and-clear", message);
+ Object result = template.requestBodyAndHeader("direct:put-and-count", null, JcloudsConstants.OPERATION, JcloudsConstants.COUNT_BLOBS, Long.class);
+ assertEquals(new Long(1), result);
+ template.requestBodyAndHeader("direct:put-and-clear", null, JcloudsConstants.OPERATION, JcloudsConstants.CLEAR_CONTAINER);
+ result = template.requestBodyAndHeader("direct:put-and-count", null, JcloudsConstants.OPERATION, JcloudsConstants.COUNT_BLOBS, Long.class);
+ assertEquals(new Long(0), result);
+ }
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
@@ -115,6 +126,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-clear")
+ .setHeader(JcloudsConstants.BLOB_NAME, constant(TEST_BLOB_IN_DIR))
+ .setHeader(JcloudsConstants.CONTAINER_NAME, constant(TEST_CONTAINER))
+ .to("jclouds:blobstore:transient");
}
};
}
http://git-wip-us.apache.org/repos/asf/camel/blob/5bad8c08/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java b/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java
index 70378a4..e2c03ea 100644
--- a/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java
+++ b/components/camel-jclouds/src/test/java/org/apache/camel/component/jclouds/JcloudsSpringBlobstoreTest.java
@@ -84,4 +84,10 @@ public class JcloudsSpringBlobstoreTest extends CamelSpringTestSupport {
Long count = template.requestBody("direct:remove", "Some message", Long.class);
assertEquals(new Long(0), count);
}
+
+ @Test
+ public void testBlobStoreClear() throws InterruptedException {
+ Long count = template.requestBody("direct:clear", "Some message", Long.class);
+ assertEquals(new Long(0), count);
+ }
}
http://git-wip-us.apache.org/repos/asf/camel/blob/5bad8c08/components/camel-jclouds/src/test/resources/blobstore-test.xml
----------------------------------------------------------------------
diff --git a/components/camel-jclouds/src/test/resources/blobstore-test.xml b/components/camel-jclouds/src/test/resources/blobstore-test.xml
index 7746e55..2294b66 100644
--- a/components/camel-jclouds/src/test/resources/blobstore-test.xml
+++ b/components/camel-jclouds/src/test/resources/blobstore-test.xml
@@ -60,6 +60,13 @@
<to uri="jclouds:blobstore:transient?container=foo&blobName=testName&operation=CamelJcloudsRemoveBlob"/>
<to uri="jclouds:blobstore:transient?container=foo&blobName=testName&operation=CamelJcloudsCountBlobs"/>
</route>
+
+ <route>
+ <from uri="direct:clear"/>
+ <to uri="jclouds:blobstore:transient?container=foo&blobName=testName"/>
+ <to uri="jclouds:blobstore:transient?container=foo&blobName=testName&operation=CamelJcloudsClearContainer"/>
+ <to uri="jclouds:blobstore:transient?container=foo&blobName=testName&operation=CamelJcloudsCountBlobs"/>
+ </route>
</camelContext>