Spring-integration-java-dsl by manojp1988

Welcome to my Github Spring-integration-java-dsl repository!

This repository contains samples, questions&answers posted to spring-integration authors. Thanks to @garyrussell and @artembilan for their support.

Why dsl than xml?

Java dsl is better in a way that we don't need to write complex xml integration tags, more writing to define each components. Java dsl is more reable, more resuable.

Reference: Spring-Integration-Java-DSL-Reference.

Sample Flow:

A sample outbound gateway can have transformer which transform the canonical object to request object, header enricher which enriches header values, and call the outbound gateway and then transform the response object to canonical response object. This can be code in below dsl way.

Java configuration

  @Configuration
  @EnableIntegration // Enables integration infrastructure like channels.
  @IntegrationComponentScan // Like component scan, this will scan integration components like @MessaginGateway etc.
  @EnableMessageHistory // This enables adding message flow history in the header.
  public  class ContextConfiguration {
  }

Gateway:

  @MessagingGateway
  public interface HelloGateway {
    @Gateway(requestChannel = "helloRequestChannel")
    String sayHello(String payload);
  }

Channel definition:

 @Bean
 public MessageChannel helloRequestChannel(){
   return MessageChannels.direct().get();
 }

Integration flow:

  @Bean
  public IntegrationFlow sayHelloFlow(){
   return IntegrationFlow.from("helloRequestChannel")
                         .transform(requestTransformer)
                         .enrichHeaders(headerEnricher)
                         .handle(httpOutboundGateway)
                         .transform(responseTransformer)
                         .get();
   }

How to invoke the gateway

Invoke through simple java invocation.
Put message into the channel.

  sayHello("dsl"); // Java method invocation.

<!-- below enricher puts payload into the channel we defined above and sets into property as usual. -->
  <int:enricher input-channel="HELLO_ENRCH_CHNL"
        request-channel="helloRequestChannel">
        <int:property name="name" expression="payload.name" />
    </int:enricher>

Working example represents above can be found here.

If you see above, you can find the difference how dsl improves readability. Instead of we defining channels, spring generates channels for us. And you can see them if you enable logging.

Debugging.

All channels are created based on the flow name we define. If you see from above example, spring generates sayHelloFlow.channel#0, sayHelloFlow.channel#1 etc.

Examples:

Flow reuse. This is something we wanted to achieve using dsl. With xml, we had to same kind of flow redundantly in many places.
Advice for gateways. We can ran aop on the gateways. This is not specific to dsl though.
Global channel interceptors/.
Re-route error channel to caller..
Splitter-Aggregator
Expression based router.
Recipient list router.
Header value router.

More will come...

Spring-integration-java-dsl

Welcome to my Github Spring-integration-java-dsl repository!

Sample Flow:

Debugging.

Examples:

Questions: