Вопросы по теме 'spring-integration-dsl'
Использование Spring Integration и проверка подходов
На данный момент я тестирую использование Spring Integration, чтобы связать вместе разрозненные модули в одном приложении Spring-Boot и службы в единый поток, начиная с единой точки входа.
Если возможно, я ищу следующие пояснения по поводу Spring...
586 просмотров
schedule
23.05.2023
Трансформатор Spring Integration DSL
Могу ли я получить помощь по следующей проблеме: при вызове преобразователя для преобразования входного объекта в объект карты и вызове обработчика в обработчике отсутствуют значения заголовка, добавленные ранее. Почему при преобразовании полезной...
1061 просмотров
schedule
06.03.2022
Как пропустить строку заголовка (первую строку) файла в springcloudstream с помощью DSL?
Я использую облачный поток Spring для чтения файла и разделения с помощью разделителя файлов и выделения каждой строки в виде сообщения с использованием стиля DSL, файл, который я читаю, имеет строку заголовка, просто интересно, есть ли простой способ...
382 просмотров
schedule
29.04.2023
Spring Integration Использование устаревшего класса DSL
Я использую весеннюю интеграцию и зависимости java-dsl с этими версиями.
пружинная интеграция-jdbc- 5.0.0M6
пружина-интеграция-WS- 5.0.0M6
Весна-интеграция-http- 5.0.0M6
пружинная интеграция-jmx- 5.0.0M6
пружина-интеграция-ядро- 5.0.0M6...
868 просмотров
schedule
07.02.2023
Spring Integration перехватывает прямой MessageChannel для тестирования
Я хочу провести интеграционный тест двух приложений Spring Boot, которые также используют потоки Spring Integration. Чтобы протестировать свои приложения, я хочу проверить сообщения, направляемые через myMessageChannel . Он определяется в потоке...
1123 просмотров
schedule
31.03.2023
Представление пула потоков в Spring Integration, а не в ExecutorService
В настоящее время в одном из наших приложений существует код, подобный следующему:
@Component
public class ProcessRequestImpl {
private ExecutorService executorService;
public processRequest(...) {
// code to pre-process request...
103 просмотров
schedule
23.08.2022
Ошибка HttpRequestExecutingMessageHandler с использованием Spring Http.outboundGateway dsl
Я вижу следующую ошибку при использовании Http.outboundGateway. Может ли кто-нибудь помочь, где я ошибаюсь
@Bean
public IntegrationFlow syncProcessFlow() {
return
// dsl code to fetch a message from Queue
......
1762 просмотров
schedule
09.10.2022
Динамический HTTP-шлюз входящей почты с использованием Spring-integration-dsl
Я пытаюсь создать и зарегистрировать поток интеграции времени выполнения для входящего HTTP-шлюза с использованием Java DSL, как показано ниже.
@Autowired
private IntegrationFlowContext flowContext;
public static void main(String[] args) {...
1993 просмотров
schedule
30.10.2022
Spring-integration: отправка сообщений из очереди выборочному потребителю
У меня есть поток интеграции Spring, который создает сообщения, которые следует хранить в ожидании, пока соответствующий потребитель придет и потребует их.
@Bean
public IntegrationFlow messagesPerCustomerFlow() {
return IntegrationFlows....
304 просмотров
schedule
12.02.2023
Ошибка при модульном тестировании весенней интеграции dsl
Я вижу следующую ошибку при запуске модульного тестирования моего кода интеграции Spring. А также я не был уверен, как издеваться над моей службой и другими зависимостями при использовании mockIntegrationContext....
319 просмотров
schedule
16.06.2022
Spring интеграция с Redis Poller с транзакцией
Я использую spring integeration redis, сообщение опроса от redis, например:
@Bean
public PseudoTransactionManager transactionManager() {
final PseudoTransactionManager pseudoTransactionManager = new PseudoTransactionManager();
return...
260 просмотров
schedule
06.03.2023
Использование Nio Locker в весенней интеграции java dsl для опроса файлов
Я пытаюсь реализовать опрос файлов интеграции Spring, при котором несколько серверов независимо читают из общего каталога и обрабатывают файл. Каждый из них после обработки файла переименовывает его в .DONE, чтобы другой его не выбирал. Наблюдая за...
268 просмотров
schedule
25.04.2023
Spring Integration 5.07 Использование Java DSL для моста между двумя очередями JMS
Мне нужно регулировать перемещение сообщений между некоторыми очередями JMS (activeMQ), чтобы гарантировать, что я не переполню внешнюю службу, используемую во время обработки сообщений.
Я делал это в прошлом с Camel, но, учитывая, что в остальном...
773 просмотров
schedule
21.06.2023
Spring Integration DSL: Dispatcher не имеет подписчиков
У меня есть требование получить zip-файл с использованием SFTP. После этого мы должны заархивировать файл как есть, также обрабатывает файл после распаковки zip-файлов. Ниже приведены коды для основного потока и подпотока....
841 просмотров
schedule
19.04.2022
RequestHandlerRetryAdvice нельзя заставить работать с Ftp.outboundGateway в Spring Integration
Моя ситуация аналогична описанной в это ТАК вопрос . Разница в том, что я использую не WebFlux.outboundGateway , а Ftp.outboundGateway , для которого я вызываю команду AbstractRemoteFileOutboundGateway.Command.GET , а общая проблема заключается в...
296 просмотров
schedule
01.11.2023
Какой хороший способ зарегистрировать смежные HTTP-запросы с помощью потока интеграции Spring
Каков хороший способ зарегистрировать смежные HTTP-запросы в потоке интеграции Spring?
Мое приложение:
Для каждого покупателя (есть свой поток, запуск которого назначает опросчик)
Операция GET 1 в исходном приложении, результат - JSON_1....
46 просмотров
schedule
14.04.2022
Spring-Integration обработка исключений Webflux
Если исключение возникает в потоке webflux весенней интеграции, само исключение (с stacktrace) отправляется обратно вызывающей стороне в виде полезной нагрузки через MessagePublishingErrorHandler, который использует канал ошибки из заголовка...
375 просмотров
schedule
02.04.2022
Как написать JUnit для операции Spring Integration DSL Http.outboundGateway
Как написать JUnit для следующей операции Spring Integration DSL Http.outboundGateway:
integrationFlowBuilder
.from(integerMessageSource(),
c -> c.poller(Pollers.cron("0 0/1 * 1/1 * ?")
.handle(Http...
173 просмотров
schedule
31.08.2022
Spring Integration Java DSL: как продолжить после ошибочной ситуации методы разделения и агрегирования?
Моя программа делает следующее на высоком уровне
Task 1
get the data from the System X
the Java DSL split
post the data to the System Y
post the reply data to the X
the Java DSL aggregate
Task 2
get the data from the System X
the...
509 просмотров
schedule
27.07.2023
Как сбалансировать нагрузку лидера, используя интеграцию zookeeper и spring
Используя интеграцию spring и zookeeper, можно реализовать лидера для выполнения таких действий, как опрос.
Однако как распределить ответственность лидера на все узлы в кластере для балансировки нагрузки?
Приведенный ниже код, как только...
617 просмотров
schedule
01.04.2024
