Вопросы по теме 'spring-integration-dsl'
Интеграция Spring: интеграция REST с JMS дает ошибку тайм-аута
Привет, я пытаюсь реализовать следующий поток, используя Spring Integration. Откройте службу REST, управляйте полезной нагрузкой, запишите измененную полезную нагрузку в JMS и ответьте обратно службе REST.
@Bean
public IntegrationFlow...
364 просмотров
schedule
11.03.2022
Spring Integration Неправильный заголовок хоста
У нас возникла эта странная проблема с заголовком узла запроса, установленным в качестве URL-адреса приложения. Это приводит к тому, что внешняя система не обрабатывает наши запросы.
Вот журнал DEBUG apache Spring Integration application ,...
362 просмотров
schedule
17.12.2023
Значения заголовка, установленные после разделителя, не поступают после агрегации с использованием Spring интеграции dsl
Я использую Spring Integration dsl для следующих требований.
Требование состоит в том, что я должен разделить сообщение с помощью разделителя и добавить значение заголовка к разделению сообщения сообщения во время некоторого преобразования, а затем...
51 просмотров
schedule
06.11.2023
Создание стратегии выпуска Spring интеграции с использованием Spring DSL
Я новичок в интеграции Spring. Я пытаюсь разделить сообщение из файла с помощью разделителя файлов, а затем использовать .aggregate () для создания одного сообщения и отправки в выходной канал. У меня есть маркеры как истинные, и, следовательно,...
463 просмотров
schedule
30.11.2022
Что означает «int» при использовании в конфигурациях xml при интеграции spring?
В настоящее время я читаю темы весенней интеграции. Наткнулся на нотацию/префикс --> "int", используемый в конфигурациях XML в spring-integration.
<int:channel id="errorChannel">
<int:queue capacity="500"/>
Can anyone help me...
311 просмотров
schedule
14.12.2022
Как ускорить потребление очереди sqs, используя интеграцию spring
Я пытаюсь настроить поток интеграции для приема сообщений из очереди amazon sqs, и пока он работает нормально. Но я хотел бы определить количество сообщений в минуту или секунду. например 20 сообщений в минуту.
Вот определение моего компонента...
1081 просмотров
schedule
11.11.2023
Переопределить Fastxml jackson ObjectMapper, используемый Spring Integration dsl
Используя Transformers.toJson (), моя дата json выглядит так:
«createdDate»: {«год»: 2017, «месяц»: «ОКТЯБРЬ», «monthValue»: 10, «dayOfMonth»: 25, «час»: 7, «минута»: 57, «секунда»: 36, " nano ": 972000000," dayOfWeek ":" WEDNESDAY "," dayOfYear...
523 просмотров
schedule
23.07.2023
Остановка TCP-адаптера с помощью Client ConnectionFactory
Я пытаюсь остановить адаптер TCP с фабрикой клиентских подключений с помощью команды шины управления, то есть @AdapterID.stop() . Код для создания потока приведен ниже:
IntegrationFlow flow =...
216 просмотров
schedule
22.02.2022
Spring Integration Java DSL HTTP ответ не получен из-за ошибки тайм-аута
Я использую интеграцию Spring 5.0.6. Я прошел через этот документ и создал следующий код, который прослушивает конечную точку HTTP и публикует в теме kafka.
Все работает нормально, и я также получаю сообщение в теме. Но на HTTP-клиенте ответ не...
546 просмотров
schedule
17.05.2024
Шлюз Spring-Integeration SFTP для работы с Mput
Я пытаюсь загрузить несколько файлов, используя исходящий шлюз SFTP. Мой код Java выглядит так:
final DirectChannel reqWriteChannel = (DirectChannel) context.getBean("toWriteChannel");
final PollableChannel repWriteChannel = (PollableChannel)...
326 просмотров
schedule
09.02.2024
Триггер SpringIntegration Cron
Привет, я использую SpringIntegration с триггером для опроса каталога. Пока все хорошо.
Но у меня проблема с временем начала и окончания опроса, например, 12:05 и 18:15.
0 0/1 12-18 ? * MON-FRI
Выше работает нормально каждую минуту между...
88 просмотров
schedule
11.08.2022
Интеграция Spring Java DSL: как совместно использовать переменную заголовка в одном запуске потока интеграции
Псевдокод моего потока
@Bean
private IntegrationFlow myChannel() {
return f -> f
.enrichHeaders(h -> h.header("x", "y", true))
.split(...)
...
..handle("myHandler", "doMyWork")...
263 просмотров
schedule
29.03.2022
Как разрешить обработчик и метод динамически из заголовков?
Мой поток такой
private IntegrationFlow myChannel() {
return f -> f
...
.handle("myHandler", "myMethod")
...
}
Как разрешить обработчик myHandler и метод myMethod динамически из заголовков?
18 просмотров
schedule
13.03.2023
Spring Integration DSL, опрос из канала сообщений
У меня есть служба, которая отправляет данные в канал сообщений. Мне интересно, как я могу указать поток интеграции для опроса из этого канала сообщений каждые X секунд и чтения всех данных, которые до сих пор не были прочитаны. Я пытаюсь добиться...
482 просмотров
schedule
16.11.2023
Весенняя интеграция: невозможно провести выборы лидера с помощью смотрителя зоопарка
Я пытаюсь выбрать лидера среди контейнеров моего приложения, чтобы выполнить какую-то задачу
Я написал следующий код,
@Configuration
@EnableIntegration
public class LeaderConfiguration {
@Bean
public LeaderInitiatorFactoryBean...
1187 просмотров
schedule
24.05.2023
Как отправить ответ обратно в интерфейс шлюза?
В настоящее время я получаю эту ошибку:
DestinationResolutionException:
no output-channel or replyChannel header available .
У меня есть файловый шлюз, который внедрен в контроллер
@MessagingGateway
public interface FileGateway...
88 просмотров
schedule
27.12.2022
Spring Integration DSL отвечает успешно, если успешная доставка в очередь
Я пытаюсь открыть конечную точку HTTP, которая отправит сообщение в очередь JMS. Я хочу ответить Успехом, если доставка прошла успешно, и ОШИБКОЙ, если сообщение не может быть доставлено.
@Bean
public IntegrationFlow...
32 просмотров
schedule
19.12.2023
Интеграция Spring - получатель почты imap
Я использую Spring boot 2.2.4-RELEASE и Spring Integration 5.2.3, и я использую IntegrationFlow и DSL, потому что мне нужно настроить несколько серверов IMAP.
Итак, я написал этот код:
String flowId =...
871 просмотров
schedule
25.01.2024
Интеграция Spring: запускать опрос JPA только после обработки всех результатов последнего опроса
У меня есть следующий поток, который я хотел бы реализовать с помощью Spring Integration Java DSL:
Опрашивать таблицу в базе данных каждые 2 часа, которая возвращает идентификатор документов, которые необходимо обработать.
Для каждого...
393 просмотров
schedule
30.06.2022
Способ получения сообщений из предыдущих потоков в линейной цепочке
Недавно у меня был сценарий, как показано ниже:
Flow_A ------> Flow_B ------> Flow_C ------> Flow_D
Где
Flow_A является инициатором и должен передать messageA.
Flow_B должен передать сообщениеA+сообщениеB.
Flow_C должен...
27 просмотров
schedule
29.03.2023
