Вопросы по теме 'spring-integration-dsl'
Как поместить сообщение в очередь в формате json с помощью Spring Integration AMQP
В настоящее время я пытаюсь поставить сообщение в очередь с форматом json. Ниже мой фрагмент кода, но он не работает.
return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, NOTE_INCOMING_QUEUE)...
560 просмотров
schedule
04.06.2022
Интеграция с Spring — передача данных между потоками
У меня есть специальный IntegrationFlow, настроенный как
@Bean
public IntegrationFlow setupRabbitFlow() {
return IntegrationFlows.from(myInputChannel)
.handle((p, h) -> rabbitPublisher.publishToRabbit(p, h))...
615 просмотров
schedule
10.06.2022
Spring Integration Java DSL - В чем разница между классом HeaderEnricher и HeaderEnricherSpec
Я изучаю DSL до Java8 для весенней интеграции и пробую несколько примеров из существующих компонентов интеграции, доступных в моем проекте. Для обогащения заголовков я нашел два класса: HeaderEnricher и HeaderEnricherSpec.
В чем разница между...
237 просмотров
schedule
01.07.2022
Spring Integration HTTP Outbound Gateway Post Request с Java DSL
Я пытаюсь использовать службу отдыха, получить обратно json и преобразовать его в список объектов. но я получаю следующий erorr. Я новичок в EIP, и в java dsl не так много руководств по этому поводу. Я настроил 2 канала, один для отправки запроса и...
3820 просмотров
schedule
18.01.2023
Spring интеграция java dsl - java 7 - установить опросчик в адаптере исходящего канала
Я пытаюсь перенести часть своего кода из XML в стиль java dsl (pre-java8).
Это созданная мной конфигурация java, я не могу понять, как настроить опросчик. Примеры говорят только о глобальном опросчике, но в моем случае мне нужно установить...
374 просмотров
schedule
08.06.2022
Как управлять новым сообщением, содержащим текущий идентификатор корреляции, в потоке исключений
После сплиттера возникает исключение при обработке сообщения. Я хочу обработать это исключение и направить в общий канал новое сообщение с идентификатором корреляции того сообщения, которое породило исключение, и специальным заголовком, указывающим...
330 просмотров
schedule
10.02.2023
Канал настраиваемых ошибок DSL Spring Integration не работает
Я использую DSL-реализацию Spring Integration. У меня есть код ниже, и я не могу использовать свой собственный поток ошибок. Когда метод аутентификации выдает исключение времени выполнения, errorChannel начинает обработку. Я дополняю заголовок,...
5300 просмотров
schedule
14.04.2022
Настройте подпоток как компонент для PublishSubscribeChannel в Spring интеграции DSL
Согласно разделу Поддержка подпотоков руководства, можно было бы ожидать, что можно будет очень просто настроить подпоток: с помощью фабрик DSL или лямбда-выражений.
// This is modified example from the guide.
@Bean
public IntegrationFlow...
432 просмотров
schedule
10.09.2022
Spring Integration Java DSL - многоразовый объект в потоке
Я новичок в Spring Integration DSL, и у меня возникла проблема. Мне нужно использовать Object с начала потока в определенной точке в subFlow или в любой другой точке потока, что-то вроде переменной Session, которую можно повторно использовать во всем...
961 просмотров
schedule
16.04.2022
Интеграция Spring: как настроить все исходящие сообщения об ошибках
Мне нужно настроить все сообщения об ошибках, возвращающиеся к вызывающей стороне моих потоков интеграции, чтобы не допустить утечки информации, независимо от того, выдаются ли они как исключение или обрабатываются как асинхронные ошибки. Я хотел бы...
32 просмотров
schedule
25.06.2023
Оптимизация использования сообщений от rabbitmq с помощью Spring Integration
Я пытаюсь создать IntegrationFlowFactory, чтобы легко создавать потоки интеграции для передачи событий между контекстами приложения.
Кажется, все работает, и события публикуются очень быстро.
Однако я не могу понять, почему потребление так...
164 просмотров
schedule
13.11.2022
Условный обработчик в потоке интеграции
Я разрабатываю службу уведомлений веб-крючков, которая позволяет клиентам подписываться/отписываться от сообщений, проходящих через промежуточное ПО, и получать уведомления о сообщениях (в соответствии с предоставленными критериями), отправляя...
1216 просмотров
schedule
10.07.2022
Обработчики активатора службы не работают последовательно
Я не могу запустить обработчики активатора службы последовательно, похоже, они не запускаются один за другим. В приведенном ниже коде метод fileWriterMessageHandler вызывается перед методом fileUpload. Каково стандартное возвращаемое значение,...
272 просмотров
schedule
22.04.2023
Интеграция Spring - предполагаемые типы AMQP в Java DSL?
Я работал над «асфальтированной дорогой» для настройки асинхронного обмена сообщениями между двумя микросервисами с использованием AMQP. Мы хотим продвигать использование отдельных объектов домена для каждой службы, а это означает, что каждая служба...
405 просмотров
schedule
26.05.2022
Spring Integration DSL - результаты JdbcPollingChannelAdapter не в очереди
Клянусь, у меня это сработало, но когда я смогу вернуться к нему через несколько месяцев (и после обновления до Boot 1.5.9), у меня возникнут проблемы.
Я установил JdbcPollingChannelAdapter, на котором я могу выполнять функцию receive (), но когда...
762 просмотров
schedule
07.06.2023
Проверка интеграции Spring в потоке разделения и агрегирования
Я пытаюсь добавить фильтр, чтобы отбросить поток и продолжить выполнение основного потока даже после сбоя и агрегировать разделитель. ожидаемый тип как для ошибки, так и для успеха одинаков. конкретной логики агрегатора нет.
@Bean
public...
707 просмотров
schedule
04.04.2023
Как демаршалировать xml с помощью Spring интеграции dsl
Я работаю над весенней интеграцией dsl. Требование - прочитать XML-сообщение из очереди на основе значения заголовка сообщения, мне нужно вызвать другую службу. Мне удалось получить сообщение из очереди, но не смог написать код в dsl для...
797 просмотров
schedule
12.12.2021
Http Outbound Gateway Post с полезной нагрузкой
Я использую поток интеграции для отправки запроса POST. Я хотел бы знать, как я могу указать тело запроса?
IntegrationFlow myFlow() {
return IntegrationFlows.from("requestChannel")
.handle(Http.outboundGateway(uri)...
464 просмотров
schedule
16.03.2024
spring-integration: Webflux inboundGateway не сопоставлен с запросом
Я настроил пример приложения с ресурсом /sse webflux, который создает текст/поток событий.
Когда я пытаюсь вызвать ресурс с помощью curl, я получаю 404 при запросе без заголовка Accept и 406 при запросе с заголовком Accept следующим образом:...
883 просмотров
schedule
08.01.2023
Динамическое создание клиента TCP с входящим каналом и каналом ответа
Я новичок в интеграции Spring.
Работа с Spring 4, только аннотации Java.
В проекте, в котором я сейчас работаю, мы настроили TCP-соединение в файле свойств.
На данный момент он жестко запрограммирован только на 2 разных соединения, и его...
495 просмотров
schedule
23.06.2022
