Camel JSON Content Enricher

EnrichJson.java

package eu.janbednar.stackoverflow;

import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jackson.JacksonDataFormat;
import org.apache.camel.spi.DataFormat;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Assert;
import org.junit.Test;

import java.util.Map;

public class EnrichJson extends CamelTestSupport {

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                DataFormat json = new JacksonDataFormat();

                from("direct:json")
                    .unmarshal(json)
                    .enrich("direct:callService", (original, response) -> {
                        original.getIn().getBody(Map.class).put(
                                "text_1",
                                response.getIn().getBody(String.class)
                        );
                        return original;
                    })
                    .marshal(json)
                    .to("log:result");

                from("direct:callService")
                    .setHeader(Exchange.HTTP_METHOD, constant("POST"))
                    .setBody(simple("${body[text_1]}"))
                    .to("http4://httpbin.org/post");
            }
        };
    }

    @Test
    public void test() throws Exception {
        String result = template.requestBody("direct:json",
                "{" +
                "  \"text_1\": \"some text input\"," +
                "  \"text_2\": \"some other text input\"" +
                "}",
                String.class
        );

        Assert.assertTrue(result.contains("httpbin.org"));
    }
}