我有一个服务,它从不同的消息队列接收不同的结构化消息。让@StreamListener conditions
我们可以在每种消息类型中选择应该如何处理该消息。举个例子:
我们收到两种不同类型的消息,它们具有不同的标头字段和值,例如
从“订单”队列传入:
Order1: { Header: {catalog:groceries} }
Order2: { Header: {catalog:tools} }
从“装运”队列传入:
Shipment1: { Header: {region:Europe} }
Shipment2: { Header: {region:America} }
每个队列都有一个绑定,据此@StreamListener
我可以按目录和区域不同地处理消息
例如
@StreamListener(target = OrderSink.ORDER_CHANNEL, condition = "headers['catalog'] == 'groceries'")
public void onGroceriesOrder(GroceryOder order){
...
}
所以问题是,如何使用新的 Spring Cloud Function 方法来实现这一点?
Also, for SpEL, the root object of the evaluation context is Message so you can do evaluation on individual headers (or message) as well ….routing-expression=headers['type']
是否可以将路由表达式添加到绑定中,例如 (in application.yml
)
onGroceriesOrder-in-0:
destination: order
routing-expression: "headers['catalog']==groceries"
?
第一次回答后编辑 如果在这个位置上面的表达式是不可能的,第一个答案意味着什么,我的问题如下:
据我了解,routing-expression: headers['catalog']
必须全局设置类似的表达式,因为结果映射到某些(消费者)函数。
我如何控制每个队列上的 2 条不同消息将被转发到它们自己的消费者函数,例如
Order1 --> MyOrderService.onGroceriesOrder()
Order2 --> MyOrderService.onToolsOrder()
Shipment1 --> MyShipmentService.onEuropeShipment()
Shipment2 --> MyShipmentService.onAmericaShipment()
使用 很容易@StreamListener
,因为每个方法都有自己的@StreamListener
注释,具有不同的条件。新设置如何实现这一点routing-expression
??