如何在 Spring xd 中为 RabbitMQ 动态指定路由键

Question

我正在尝试使用
在 SpringXD 中设置 RabbitMQ Sink 的路由键值 '{$payload.routingkey'}

由于有效负载承载了整个消息，我的消息是 json {"routingkey":"Disney","text":"DisneyTweet"}

但是报错报错

  java.lang.IllegalArgumentException: Could not resolve placeholder 'payload.routingKey' in string value "${payload.routingKey}"

如何根据消息中的值设置 Routingkey

Answer 1

删除 $

--routingKey='payload.routingkey'"

它使用 SpEL Json 属性访问器。

或者您可以使用 jsonPath SpEL 函数：

--routingKey='#jsonPath(payload, \"$.routingkey\")'"

How to specify Routing key dynamically in Spring xd for RabbitMQ