Spring-Integration

Many frameworks or middlewares have the same concept and desgin principle.

EIP：

 

Flume:

 

Storm:

 

Spring:

 

 

 

@Configuratiom
public class SomeConfiguration {

    @Bean("someService.handler")
    @EndpointId("someService")
    @ServiceActivator(inputChannel = ...)
    public MessageHandler someHandler() {
        ...
    }

}

@Component
public class SomeComponent {

    @EndpointId("someService")
    @ServiceActivator(inputChannel = ...)
    public String someMethod(...) {
        ...
    }

}

 

 Netty:

 

 

 

 

 

 

Spark:

Flink: