Как присвоить больший приоритет указанному процессу c IntegrationFlow, когда существует несколько IntegrationFlow с SpringIntegration - PullRequest
0 голосов
/ 28 февраля 2020

Я хочу приписать больше ресурсов (приоритет потока) указанному c процессу IntegrationFlow, когда несколько экземпляров IntegrationFlow выполняются в одном приложении SpringBoot с использованием SpringIntegration.

У меня есть два экземпляра IntegrationFlow, связанных с два разных типа источников. Один связан с источником SFTP, а другой связан с источником данных. Когда SFTP-сообщение используется после нескольких шагов (распакуйте файлы, содержащие XML файлы, проверьте правильность XML файлов по схеме XSD, разбейте файлы XML и сохраните данные, соответствующие части файла XML), второй рабочий процесс работает в parralel, потребляет все сохраненные данные из источника данных, чтобы поместить их sh в топику Кафки c. Поэтому я хочу приписать больше ресурсов на первом IntegrationFlow. Для каждого InegrationFlow максимальный размер выборки устанавливается равным единице.

...