Я обновил свою версию 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
Проблема с разворачиванием заголовка Spring-Integration ⇐ JAVA
Программисты JAVA общаются здесь
-
Anonymous
1730196871
Anonymous
Я обновил свою версию [b]spring-integration[/b] [b]1.5.4[/b] до [b]spring-integration-core 6.3.4[/b], после чего я столкнулся с заголовком проблема в [b]routeToRecipients[/b], поэтому всякий раз, когда я хочу получить информацию о заголовке здесь, объект сообщения преобразует только [b]OrderMessage[/b] и, естественно, я получаю исключение приведения. Кстати, мой брокер сообщений - 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))
Подробнее здесь: [url]https://stackoverflow.com/questions/79136739/spring-integration-header-unwrap-issue[/url]
Ответить
1 сообщение
• Страница 1 из 1
Перейти
- Кемерово-IT
- ↳ Javascript
- ↳ C#
- ↳ JAVA
- ↳ Elasticsearch aggregation
- ↳ Python
- ↳ Php
- ↳ Android
- ↳ Html
- ↳ Jquery
- ↳ C++
- ↳ IOS
- ↳ CSS
- ↳ Excel
- ↳ Linux
- ↳ Apache
- ↳ MySql
- Детский мир
- Для души
- ↳ Музыкальные инструменты даром
- ↳ Печатная продукция даром
- Внешняя красота и здоровье
- ↳ Одежда и обувь для взрослых даром
- ↳ Товары для здоровья
- ↳ Физкультура и спорт
- Техника - даром!
- ↳ Автомобилистам
- ↳ Компьютерная техника
- ↳ Плиты: газовые и электрические
- ↳ Холодильники
- ↳ Стиральные машины
- ↳ Телевизоры
- ↳ Телефоны, смартфоны, плашеты
- ↳ Швейные машинки
- ↳ Прочая электроника и техника
- ↳ Фототехника
- Ремонт и интерьер
- ↳ Стройматериалы, инструмент
- ↳ Мебель и предметы интерьера даром
- ↳ Cантехника
- Другие темы
- ↳ Разное даром
- ↳ Давай меняться!
- ↳ Отдам\возьму за копеечку
- ↳ Работа и подработка в Кемерове
- ↳ Давай с тобой поговорим...
Мобильная версия