在Spring Integration DSL中使用带丢弃通道的滤波器

Question

StandardIntegrationFlow flow = IntegrationFlows.from(...)
                    .filter(messagingFilter)
                    .transform(transformer)
                    .handle((m) -> {
                        (...)
                    })
                    .get();

StandardIntegrationFlow flow = IntegrationFlows.from(...)
                    .filter(messagingFilters, fs -> fs.discardFlow( i -> i.channel(discardChannel()))
                    .transform(transformer)
                    .handle((m) -> {
                        (...)
                    })
                    .get();

(...)

public MessageChannel discardChannel() {
    MessageChannel channel = new MessageChannel(){
        @Override
        public boolean send(Message<?> message) {
            log.warn((String) message.getPayload().get("msg-failure"));
            return true;
        }
        @Override
        public boolean send(Message<?> message, long timeout) {
            return this.send(message);
        }
    };
    return channel;
}

这既难看又冗长，所以问题是，我在这里做错了什么，我应该如何以更好、更干净、更优雅的解决方案来做？

干杯。

Answer 1

您的问题是，您没有看到过滤器是一个EI模式实现，它所能做的最多是将丢弃的消息发送到某个通道。它不会记录任何东西，因为这种方法已经不是基于消息传递的了。

您需要的用例最简单的方式如下：

.discardFlow(df -> df
        .handle(message -> log.warn((String) message.getPayload().get("msg-failure")))))

你的逻辑就是记录。其他一些人可能会做更复杂的逻辑。因此，最终您将习惯于endpoint之间的通道抽象。

 .filter(messagingFilters, fs -> fs.discardFlow( i -> i.log(message -> (String) message.getPayload().get("msg-failure"))))