You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bv...@apache.org on 2020/12/02 20:20:55 UTC
[camel] branch fix-disabled-test-and-some-minor-cleanups updated:
fix the test using the idempotentConsumer EIP
This is an automated email from the ASF dual-hosted git repository.
bvahdat pushed a commit to branch fix-disabled-test-and-some-minor-cleanups
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/fix-disabled-test-and-some-minor-cleanups by this push:
new b53abc6 fix the test using the idempotentConsumer EIP
b53abc6 is described below
commit b53abc63bbfb86e9f7dd9ab2adb123fb4fef838f
Author: Babak Vahdat <bv...@apache.org>
AuthorDate: Wed Dec 2 21:20:32 2020 +0100
fix the test using the idempotentConsumer EIP
---
.../azure/storage/blob/integration/BlobConsumerITTest.java | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobConsumerITTest.java b/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobConsumerITTest.java
index 6927fcb..6c4eb32 100644
--- a/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobConsumerITTest.java
+++ b/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobConsumerITTest.java
@@ -31,6 +31,7 @@ import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.azure.storage.blob.BlobConstants;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.support.processor.idempotent.MemoryIdempotentRepository;
import org.apache.commons.lang3.RandomStringUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -65,8 +66,6 @@ class BlobConsumerITTest extends BaseIT {
containerClient = serviceClient.getBlobContainerClient(containerName);
batchContainerClient = serviceClient.getBlobContainerClient(batchContainerName);
- configuration.setContainerName(batchContainerName);
-
// create test container
containerClient.create();
batchContainerClient.create();
@@ -164,16 +163,18 @@ class BlobConsumerITTest extends BaseIT {
// create pdf blobs
for (int i = 0; i < 10; i++) {
+ final int index = i;
templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
- exchange.getIn().setBody("Block Batch Blob Test");
+ exchange.getIn().setBody("Block Batch PDF Blob with RegEx Test: " + index);
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, batchContainerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, generateRandomBlobName("regexp-test_batch_blob_", "pdf"));
});
}
for (int i = 0; i < 5; i++) {
+ final int index = i;
templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
- exchange.getIn().setBody("Block Batch Blob Test");
+ exchange.getIn().setBody("Block Batch PDF Blob with Prefix Test: " + index);
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, batchContainerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, generateRandomBlobName("aaaa-test_batch_blob_", "pdf"));
});
@@ -181,8 +182,9 @@ class BlobConsumerITTest extends BaseIT {
// create docx blobs
for (int i = 0; i < 20; i++) {
+ final int index = i;
templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
- exchange.getIn().setBody("Block Batch Blob Test");
+ exchange.getIn().setBody("Block Batch DOCX Blob Test: " + index);
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, batchContainerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, generateRandomBlobName("regexp-test_batch_blob_", "docx"));
});
@@ -233,6 +235,7 @@ class BlobConsumerITTest extends BaseIT {
// if regex is set then prefix should have no effect
from("azure-storage-blob://cameldev/" + batchContainerName
+ "?blobServiceClient=#serviceClient&prefix=aaaa®ex=" + regex)
+ .idempotentConsumer(body(), new MemoryIdempotentRepository())
.to("mock:resultRegex");
}
};