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

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


The following commit(s) were added to refs/heads/camel-2.x by this push:
     new 72e426a  Added unit test example based on user forum issue with 
Multicast EIP change due to CAMEL-9444 and CAMEL-9573. Using claim check EIP
72e426a is described below

commit 72e426ac5a7fec2b91731aa51a8abfdf5d337512
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Feb 8 15:15:48 2019 +0100

    Added unit test example based on user forum issue with Multicast EIP change 
due to CAMEL-9444 and CAMEL-9573. Using claim check EIP
---
 ...astMixOriginalMessageBodyAndEnrichedHeadersClaimCheckTest.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/camel-core/src/test/java/org/apache/camel/issues/MulticastMixOriginalMessageBodyAndEnrichedHeadersClaimCheckTest.java
 
b/camel-core/src/test/java/org/apache/camel/issues/MulticastMixOriginalMessageBodyAndEnrichedHeadersClaimCheckTest.java
index 6d145ab..47fd0b8 100644
--- 
a/camel-core/src/test/java/org/apache/camel/issues/MulticastMixOriginalMessageBodyAndEnrichedHeadersClaimCheckTest.java
+++ 
b/camel-core/src/test/java/org/apache/camel/issues/MulticastMixOriginalMessageBodyAndEnrichedHeadersClaimCheckTest.java
@@ -36,16 +36,18 @@ public class 
MulticastMixOriginalMessageBodyAndEnrichedHeadersClaimCheckTest ext
                 onException(Exception.class)
                     .handled(true)
                     // merge the message with the original message body but 
keep any existing headers
-                    .claimCheck(ClaimCheckOperation.Pop, "myOriginalBody", 
"body")
+                    // (we could also use Push/Pop operation instead, then 
without using the "myOriginalBody" key)
+                    .claimCheck(ClaimCheckOperation.Get, "myOriginalBody", 
"body")
                     .to("mock:b");
 
                 from("direct:start")
                     // we want to preserve the real original message body and 
then include other headers that have been
                     // set later during routing
-                    .claimCheck(ClaimCheckOperation.Push, "myOriginalBody")
+                    // (we could also use Push/Pop operation instead, then 
without using the "myOriginalBody" key)
+                    .claimCheck(ClaimCheckOperation.Set, "myOriginalBody")
                     .setBody(constant("Changed body"))
                     .setHeader("foo", constant("bar"))
-                    .multicast().shareUnitOfWork().stopOnException()
+                    .multicast().stopOnException()
                         .to("direct:a")
                         .to("direct:b")
                     .end();

Reply via email to