java - Spring Integration 事件监听器入站适配器

Question

我有一个问题，我想使用 dsl 在 Spring 集成中实现一个输入适配器，作为事件监听器，并将消息从该事件监听器重定向到 channel 。

所需代码:

@Bean
public IntegrationFlow listenerFlow() {
    return IntegrationFlows.from(InputAdapterListener.listen())
            .channel("ChannelXYZ")
            .get();
}

有人可以向我解释一下 InputAdatperListener 类的实现是什么来支持这样的行为，或者在哪里寻找一些示例？

Answer 1

spring-integration-event 中有一个 ApplicationEventListeningMessageProducer 供您在该 from() 配置中使用:

 private ApplicationListener<?> applicationListener() {
        ApplicationEventListeningMessageProducer producer = new ApplicationEventListeningMessageProducer();
        producer.setEventTypes(TestApplicationEvent1.class);
        producer.setOutputChannel(resultsChannel());
        return producer;
    }

... 

 IntegrationFlows.from(applicationListener())

这个将自动注册为一个 bean。