春云流-@StremListener条件

Question

@EnableBinding(MySink.class)
@EnableAutoConfiguration
public static class TestPojoWithAnnotatedArguments {

    @StreamListener(target = MySink.INPUT, condition = "headers['type']=='bogey'")
    public void receiveBogey(@Payload BogeyPojo bogeyPojo) {
       // handle the message
    }

    @StreamListener(target = MySink.INPUT, condition = "headers['type']=='bacall'")
    public void receiveBacall(@Payload BacallPojo bacallPojo) {
       // handle the message
    }

    @StreamListener(target = MySink.ANOTHER_INPUT, condition = "headers['type']=='bacall'")
    public void receiveBacall(@Payload BacallPojo bacallPojo) {
       // handle the message
    }
}

如何提供一个在条件不匹配时调用的处理程序？

如果我有两个处理程序，第一个有条件，第二个没有条件，当第一个条件匹配时，两个处理程序都被调用。我如何避免这种情况？

Answer 1

我们可能需要修改你提到的部分，因为它有点过时了。

此外，我们不能（不应该）基于有效负载类型进行任何类型的路由，因为数据是以串行形式从线路中传入的，比如byte[]。我在这篇旧帖子中详细讨论了它。但是您肯定可以使用传入消息的其他部分作为路由条件。推荐的最佳实践是依赖消息头。

让我们来看看这个示例：

@Bean
public Function<String, String> uppercase() {
    return v -> v.toUpperCase();
}

@Bean
public Function<String, String> lowercase() {
    return v -> v.toLowerCase();
}

@Bean
public Function<String, String> reverse() {
    return v -> new StringBuilder(v).reverse().toString();
}

--spring.cloud.function.routing-expression=headers['type'] == 'upper' ? 'uppercase' : (headers['type'] == 'lower' ? 'lowercase' : ''reverse)