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/29 14:28:59 UTC
[5/5] camel git commit: CAMEL-8918 Camel-Jclouds: Add countBlobs and
removeBlob operation to Blobstore component, add countBlobs test
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 <an...@gmail.com>
Authored: Mon Jun 29 13:46:56 2015 +0200
Committer: Andrea Cosentino <an...@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");
}
};
}