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 21:54:31 UTC
[camel] branch master updated: the default exchange pattern in
InOnly
This is an automated email from the ASF dual-hosted git repository.
bvahdat pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 88eb2ab the default exchange pattern in InOnly
88eb2ab is described below
commit 88eb2ab58e27bea9275e543607b7caa4e92d2c30
Author: Babak Vahdat <bv...@apache.org>
AuthorDate: Wed Dec 2 22:54:14 2020 +0100
the default exchange pattern in InOnly
---
.../storage/blob/integration/BlobConsumerITTest.java | 15 +++++++--------
.../storage/blob/integration/BlobProducerITTest.java | 13 ++++++-------
2 files changed, 13 insertions(+), 15 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 6c4eb32..4a18931 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
@@ -26,7 +26,6 @@ import com.azure.storage.blob.BlobContainerClient;
import com.azure.storage.blob.specialized.BlobInputStream;
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.azure.storage.blob.BlobConstants;
@@ -76,7 +75,7 @@ class BlobConsumerITTest extends BaseIT {
final MockEndpoint mockEndpoint = getMockEndpoint("mock:result");
mockEndpoint.expectedMessageCount(1);
- templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
+ templateStart.send("direct:createBlob", exchange -> {
exchange.getIn().setBody("Block Blob");
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, containerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName);
@@ -91,7 +90,7 @@ class BlobConsumerITTest extends BaseIT {
@Test
void testPollingToInputStream() throws Exception {
- templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
+ templateStart.send("direct:createBlob", exchange -> {
exchange.getIn().setBody("Block Blob");
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, containerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName2);
@@ -119,13 +118,13 @@ class BlobConsumerITTest extends BaseIT {
final MockEndpoint mockEndpointFile = getMockEndpoint("mock:resultBatchFile");
mockEndpointFile.expectedMessageCount(2);
- templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
+ templateStart.send("direct:createBlob", exchange -> {
exchange.getIn().setBody("Block Batch Blob 1");
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, batchContainerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, "test_batch_blob_1");
});
- templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
+ templateStart.send("direct:createBlob", exchange -> {
exchange.getIn().setBody("Block Batch Blob 2");
exchange.getIn().setHeader(BlobConstants.BLOB_CONTAINER_NAME, batchContainerName);
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, "test_batch_blob_2");
@@ -164,7 +163,7 @@ 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 -> {
+ templateStart.send("direct:createBlob", exchange -> {
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"));
@@ -173,7 +172,7 @@ class BlobConsumerITTest extends BaseIT {
for (int i = 0; i < 5; i++) {
final int index = i;
- templateStart.send("direct:createBlob", ExchangePattern.InOnly, exchange -> {
+ templateStart.send("direct:createBlob", exchange -> {
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"));
@@ -183,7 +182,7 @@ 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 -> {
+ templateStart.send("direct:createBlob", exchange -> {
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"));
diff --git a/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobProducerITTest.java b/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobProducerITTest.java
index 630c1e3..246b478 100644
--- a/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobProducerITTest.java
+++ b/components/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobProducerITTest.java
@@ -27,7 +27,6 @@ import java.util.Random;
import com.azure.storage.blob.BlobContainerClient;
import com.azure.storage.blob.models.PageRange;
import org.apache.camel.EndpointInject;
-import org.apache.camel.ExchangePattern;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.azure.storage.blob.BlobBlock;
@@ -64,7 +63,7 @@ class BlobProducerITTest extends BaseIT {
result.expectedMessageCount(1);
- template.send("direct:uploadBlockBlob", ExchangePattern.InOnly, exchange -> {
+ template.send("direct:uploadBlockBlob", exchange -> {
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName);
exchange.getIn().setBody("Block Blob");
});
@@ -80,7 +79,7 @@ class BlobProducerITTest extends BaseIT {
result.expectedBodiesReceived(true);
- template.send("direct:stageBlockBlobList", ExchangePattern.InOnly, exchange -> {
+ template.send("direct:stageBlockBlobList", exchange -> {
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName);
exchange.getIn().setHeader(BlobConstants.COMMIT_BLOCK_LIST_LATER, false);
@@ -101,7 +100,7 @@ class BlobProducerITTest extends BaseIT {
void testCommitAppendBlobWithError() throws InterruptedException {
final String blobName = RandomStringUtils.randomAlphabetic(10);
- template.send("direct:commitAppendBlobWithError", ExchangePattern.InOnly, exchange -> {
+ template.send("direct:commitAppendBlobWithError", exchange -> {
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName);
exchange.getIn().setHeader(BlobConstants.CREATE_APPEND_BLOB, false);
@@ -125,7 +124,7 @@ class BlobProducerITTest extends BaseIT {
result.expectedBodiesReceived(true);
- template.send("direct:commitAppendBlob", ExchangePattern.InOnly, exchange -> {
+ template.send("direct:commitAppendBlob", exchange -> {
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName);
final String data = "Hello world from my awesome tests!";
@@ -148,7 +147,7 @@ class BlobProducerITTest extends BaseIT {
result.expectedBodiesReceived(true);
- template.send("direct:uploadPageBlob", ExchangePattern.InOnly, exchange -> {
+ template.send("direct:uploadPageBlob", exchange -> {
exchange.getIn().setHeader(BlobConstants.BLOB_NAME, blobName);
byte[] dataBytes = new byte[512]; // we set range for the page from 0-511
@@ -169,7 +168,7 @@ class BlobProducerITTest extends BaseIT {
void testUploadBlockBlobWithConfigUri() throws InterruptedException {
result.expectedMessageCount(1);
- template.send("direct:uploadBlockBlobWithConfigUri", ExchangePattern.InOnly,
+ template.send("direct:uploadBlockBlobWithConfigUri",
exchange -> exchange.getIn().setBody("Block Blob"));
result.assertIsSatisfied();