Transformers

The DSL API provides a convenient, fluent Transformers factory to be used as inline target object definition within the .transform() EIP method. The following example shows how to use it:

@Bean
public IntegrationFlow transformFlow() {
    return IntegrationFlow.from("input")
            .transform(Transformers.fromJson(MyPojo.class))
            .transform(Transformers.serializer())
            .get();
}

It avoids inconvenient coding using setters and makes the flow definition more straightforward. Note that you can use Transformers to declare target Transformer instances as @Bean instances and, again, use them from IntegrationFlow definition as bean methods. Nevertheless, the DSL parser takes care of bean declarations for inline objects, if they are not yet defined as beans.

See Transformers in the Javadoc for more information and supported factory methods.

Starting with version 6.2, a transformWith(Consumer<TransformerEndpointSpec>) variant has been introduced to have all the transformer and its endpoint options to be configured via single builder argument. This style gives DSL more readability and increases developer experience while modifying code. This also make Groovy and Kotlin DSLs more straightforward.

Also see Lambdas And Message<?> Arguments.