[camel] 03/03: Added unit test based on user question

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 96c8a291cae8f3e70b23de80ee3b9ad55003afbe
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Mar 19 14:52:33 2021 +0100

    Added unit test based on user question
---
 ...dToIssue.java => InterceptSendToIssueTest.java} |  4 +++-
 ....java => InterceptSendToRecipientListTest.java} | 28 ++++++++++------------
 2 files changed, 15 insertions(+), 17 deletions(-)

diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssue.java b/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssueTest.java
similarity index 94%
copy from core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssue.java
copy to core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssueTest.java
index fc06dbe..c0bd8ef 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssue.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssueTest.java
@@ -20,14 +20,16 @@ import org.apache.camel.ContextTestSupport;
 import org.apache.camel.Exchange;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.jupiter.api.Test;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 /**
  * Based on an issue on the camel user forum.
  */
-public class InterceptSendToIssue extends ContextTestSupport {
+public class InterceptSendToIssueTest extends ContextTestSupport {
 
+    @Test
     public void testInterceptSendTo() throws Exception {
         MockEndpoint mock = getMockEndpoint("mock:foo");
         mock.expectedMessageCount(1);
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssue.java b/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToRecipientListTest.java
similarity index 59%
rename from core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssue.java
rename to core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToRecipientListTest.java
index fc06dbe..e393708 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToIssue.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/intercept/InterceptSendToRecipientListTest.java
@@ -17,28 +17,23 @@
 package org.apache.camel.processor.intercept;
 
 import org.apache.camel.ContextTestSupport;
-import org.apache.camel.Exchange;
 import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
+import org.junit.jupiter.api.Test;
 
 /**
  * Based on an issue on the camel user forum.
  */
-public class InterceptSendToIssue extends ContextTestSupport {
+public class InterceptSendToRecipientListTest extends ContextTestSupport {
 
-    public void testInterceptSendTo() throws Exception {
-        MockEndpoint mock = getMockEndpoint("mock:foo");
-        mock.expectedMessageCount(1);
-        mock.expectedHeaderReceived(Exchange.INTERCEPTED_ENDPOINT, "direct://foo");
+    @Test
+    public void testInterceptSendToRecipientList() throws Exception {
+        getMockEndpoint("mock:result").expectedMessageCount(2);
+        getMockEndpoint("mock:intercepted").expectedBodiesReceived("Hello Bar");
 
-        template.sendBody("direct:start", "Hello World");
+        template.sendBodyAndHeader("direct:start", "Hello Bar", "whereTo", "seda:beer");
+        template.sendBodyAndHeader("direct:start", "Hello Home", "whereTo", "seda:home");
 
         assertMockEndpointsSatisfied();
-
-        Exchange exchange = mock.getReceivedExchanges().get(0);
-        assertEquals("direct://start", exchange.getFromEndpoint().getEndpointUri());
     }
 
     @Override
@@ -46,10 +41,11 @@ public class InterceptSendToIssue extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                interceptSendToEndpoint("direct:foo").to("mock:foo");
+                interceptSendToEndpoint("seda:b*").skipSendToOriginalEndpoint().to("mock:intercepted");
+
+                from("direct:start")
+                    .recipientList().header("whereTo").to("mock:result");
 
-                from("direct:start").setHeader(Exchange.FILE_NAME, constant("hello.txt")).to("direct:foo");
-                from("direct:foo").log("Dummy");
             }
         };
     }