Проблема с разворачиванием заголовка Spring-IntegrationJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Проблема с разворачиванием заголовка Spring-Integration

Сообщение Anonymous »

Я обновил свою версию spring-integration 1.5.4 до spring-integration-core 6.3.4, после чего я столкнулся с заголовком проблема в routeToRecipients, поэтому всякий раз, когда я хочу получить информацию о заголовке здесь, объект сообщения преобразует только OrderMessage и, естественно, я получаю исключение приведения. Кстати, мой брокер сообщений - RabbitMQ. Я не смог найти четкого объяснения в документах или документе о миграции, введите описание ссылки здесь
@Bean
public IntegrationFlow orderRequestFlow() {
return IntegrationFlow.from(ORDER_CHANNEL)
.log(Level.TRACE, this.getClass().getName() + ".orderChannel")
.enrichHeaders(h -> h.header("source", "orderChannel"))
.handle((message, responseHeaders) -> {
OrderMessage orderMessage = (OrderMessage) jsonMessageConverter.convert(message);
Message m = MessageBuilder.withPayload(orderMessage)
.copyHeaders(responseHeaders)
.build();

return m;
})
.routeToRecipients(exhaustedRetriesRouter -> exhaustedRetriesRouter
.recipient(GenericFlow.EXHAUSTED_CHANNEL,
message ->
//the message just OrderMessage type, unwrap Message type
((Message) message).getHeaders().containsKey("x-death")
&&((Long) ((Map) ((List) ((Message) message).getHeaders().get("x-death")).get(0)).get("count") >= 3L))


Подробнее здесь: https://stackoverflow.com/questions/791 ... wrap-issue
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»