Spring云流 - 基于内容的路由

Question

我正在尝试在最新版本的 Spring Cloud 流中使用基于内容的路由。根据这份文件 -

这是我用StreamListener编写的代码

@StreamListener(target = EventChannels.FILE_REQUEST_IN
            , condition = "headers['saga_request']=='FILE_SUBMIT'")
public void handleSubmitFile(@Payload FileSubmitRequest request) {
        
}

@StreamListener(target = EventChannels.FILE_REQUEST_IN
            , condition = "headers['saga_request']=='FILE_CANCEL'")
public void handleCancelFile(@Payload FileCancelRequest request) {
        
}

通过使用该条件，可以将消息路由到两个不同的函数。

我正试图用如下的功能接口方法来消费消息。

    @Bean
    public Consumer<String> consumeMessage(){
        return event -> {
            try {
                LOGGER.info("Consumer is working: {}", event);
            } catch (Exception ex) {
                LOGGER.error("Exception while processing");
            }
        };
    }

如何在函数中实现类似的基于内容的路由？蒂亚。

其他细节-

1. Spring引导版本 - 2.3.12.发布
2. Spring云版 - Hoxton.SR11

Answer 1

你见过这个吗——https://docs . spring . io/spring-cloud-stream/docs/3 . 1 . 4/reference/html/spring-cloud-stream . html # _ event _ routing？我们提供两种不同的往返路由模型。包含的链接包含样本，所以请浏览它，并随时张贴任何后续行动