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();