Использование фильтра с каналом сброса в Spring Integration DSL

Я не знаю, касается ли этот вопрос spring-integration, spring-integration-dsl или обоих, поэтому я просто добавил 2 тега...

Сегодня я трачу значительное количество времени, сначала делая простой поток с фильтром

StandardIntegrationFlow flow = IntegrationFlows.from(...)

                    .filter(messagingFilter)

                    .transform(transformer)

                    .handle((m) -> {

                        (...)

                    })

                    .get();

MessagingFilter является очень простой реализацией MessageSelector. Пока все идет хорошо, времени почти нет. Но потом я хотел записать сообщение на случай, если MessageSelector вернет false, и вот тут я застрял.

Через некоторое время время, когда я закончил с этим:

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;

}

Ура.