[camel] branch master updated: the default exchange pattern in InOnly

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[camel] branch master updated: the default exchange pattern in InOnly

bvahdat
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 <[hidden email]>
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();