Условие StreamListener, основанное на адресе reply_to в Spring Cloud Stream (Rabbit) - PullRequest
0 голосов
/ 17 мая 2019

У меня есть приложение Spring Cloud Stream.В настоящее время используется условный прослушиватель, основанный на таком заголовке.

@StreamListener(target = Sink.INPUT, condition = "headers['reply_to'] == 'test'")
public void processMessage(Foo foo, @Header(value = "reply_to", defaultValue = "") String replyTo) {

}

Но я бы хотел использовать replyTo свойства самого сообщения, так как полученное сообщение уже имеет адрес replyTo.Есть ли в любом случае поставить условие в свойстве сообщения, а не заголовок и получить это значение как-то.

...