Wie Routing Schlüssel dynamisch im Frühjahr xd angeben, für RabbitMQ

Question

I routingkey Wert von RabbitMQ Sink in SpringXD mit
'{$ payload.routingkey'}

Als Nutzlast zu setzen versuchen trägt die gesamte Nachricht, Meine Botschaft ist ein json { "routingkey": "Disney", "text": "DisneyTweet"}

Aber es gibt Fehler beschweren

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

Wie kann ich Routingkey von einem Wert, der in meiner Nachricht ist

Answer 1

die $

--routingKey='payload.routingkey'" 

entfernen, die die Spel Json Eigenschaftenaccessor verwendet.

Oder Sie verwenden die jsonPath Spel Funktion:

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