Я использую конфигурации Spring Integration DSL. Можно ли добавить обработчик ссылки на метод, чтобы обработчик вызывался только тогда, когда полезная нагрузка сообщения соответствует типу аргумента обработчика? Например: в следующем коде, если...

Кто-нибудь делал конфигурацию spring-integration-jdbc StoredProcOutboundGateway с DSL?

Я задал несколько вопросов в разделе комментариев этой темы . Во время отладки приложения я заметил некоторые возможные ошибки кода. Это баги или фичи? В ExpressionEvaluatingRequestHandlerAdvice::evaluateSuccessExp‌​ression исключение...

Я пытаюсь создать TCP-сервер и клиент, читая файлы свойств, содержащие сведения о соединениях. Я использую потоки динамической интеграции и интеграции во время выполнения с помощью следующей ссылки document ( 9.20 Динамические потоки интеграции и...

Я реализовал IntegrationFlow , где я хочу выполнить следующие задачи: Опрос файлов из каталога Преобразование содержимого файла в строку Отправьте строку через WebFluxRequestExecutingMessageHandler в конечную точку REST и используйте...

Я новичок в интеграции spring, я хочу написать модульные тесты для своего приложения. Я работаю над приложением, в котором интерфейс интеграции будет вызываться другой системой с вводом XML, мы преобразуем входной XML с помощью XSLT и будем звонить в...

Я хочу иметь возможность обрабатывать более 10 сообщений SQS одновременно с помощью Spring Integration Workflow. Исходя из этого вопроса, было рекомендовано использовать ExecutorChannel . Я обновил свой код, но симптомы остались прежними. Как...

У меня есть поток интеграции для опроса данных из базы данных. Я установил источник сообщения, который возвращает список объектов, этот список я хочу передать методу handle в subFlow. Это код для этих целей, но я получаю сообщение об ошибке...

Я немного новичок в Spring-Integration и пытаюсь решить некоторые простые задачи. Никогда не касаясь OAuth вообще и имея службу отдыха с OAuth, я надеюсь, что кто-то может показать мне пример использования OAuth с Java DSL. В настоящее время я...

Я новичок в Spring-Integration. Мой вариант использования: Прослушайте очередь / тему RabbitMQ, получите сообщение, обработайте его, отправьте другому брокеру сообщений (в основном это будет другой экземпляр RabbitMQ). Ожидаемая нагрузка:...

Я использую весеннюю интеграцию для обработки файлов. Я хочу читать файл построчно, фильтровать, конвертировать и отправлять в кафку. Файл передается на обработку через асинхронный шлюз. В конце обработки я добавил агрегатор для двух целей: Я...

У меня проблема с моим приложением Spring Boot, когда в моем агрегаторе обрабатывается только одна группа, а затем приложение перестает потреблять больше сообщений из очереди. Кажется, он обрабатывает группу только при запуске. Я перезапустил...

Я использую API, который работает в 2 этапа: Он запускает асинхронную обработку документа, предоставляя вам идентификатор, который вы используете для шага 2. Он предоставляет конечную точку, где вы можете получить результаты, но только когда они...

Кажется, я не понимаю некоторых основных концепций обработки пользовательских исключений в Spring Integration ( Мне нужно перехватить некоторые из моих пользовательских исключений, производных от RuntimeException (выброшенных из какого-то моего...

Я пытаюсь построить поток интеграции, который предотвратит потерю сообщений во время доставки к брокеру AMQP (rabbitMQ). В случае остановки брокера я наблюдаю неожиданное для себя поведение: Неудачные сообщения сохраняются в хранилище сообщений,...