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: