Настройка свойств сообщения, созданного для RabbitMQ

Question

Мы используем весенний облачный поток, чтобы потреблять и создавать сообщения для Rabbitmq.

У нас есть требование прочитать идентификатор корреляции из входящего сообщения и установить его для создаваемого сообщения.

Мы можем прочитать то же самое, используя message.getHeaders (), но как установить его в исходящем сообщении?

При использовании MessageBuilder.setHeader () мы можем отправить значение, но в консоли управления кроликом оно отображается в заголовках, а не в свойствах.

Как производители, так и потребители для нас не используют весенний облачный поток.

Answer 1

Вы устанавливаете заголовок AmqpHeaders.CORRELATION_ID? Это отображается в / из собственности. Если вы используете что-то еще, оно будет установлено в качестве заголовка.

EDIT

у меня нормально работает ...

@Bean
public ApplicationRunner runner(MessageChannel output) {
    return args -> output.send(new GenericMessage<>("foo",
            Collections.singletonMap(AmqpHeaders.CORRELATION_ID, "foo")));
}

и

Вы уверены, что используете правильную константу?