Вопросы по теме 'spring-integration-dsl'
DSL-эквивалент Spring Integration ‹int:gateway /›
Каким будет способ Spring Integration DSL для создания эквивалента
<int:gateway service-interface="MyService" default-request-channel="myService.inputChannel"/>
// where my existing interface looks like
interface MyService { process(Foo...
1528 просмотров
schedule
18.11.2022
Spring Integration DSL добавляет транзакцию среднего потока
Я хочу сделать конкретную часть потока транзакционной. Например, я хочу выполнить первые две операции преобразования в одном транзакционном блоке. Вот код, который я использую:
@Bean
public IntegrationFlow createNumberRange() {
return...
571 просмотров
schedule
29.04.2024
Определение резервного поведения при исключении для ContentEnricher в Spring Integration
У меня есть хороший поток, определенный с помощью Spring Integration, в номинальном случае он работает так, как я хочу.
Однако я еще не нашел способа определить поведение для обработки ошибки (т.е. пометить входную строку как неудачную).
Вот...
189 просмотров
schedule
11.07.2022
Sprint Integration DSL - Http входящий адаптер и опросчик
Я новичок в Spring Integration, и я пытаюсь настроить простой вариант использования:
опрос удаленной конечной точки REST, разделение возвращаемых данных на несколько строк и отправка их исходящему адаптеру Kafka. Я успешно сделал что-то...
1047 просмотров
schedule
13.05.2022
spring-integration: MessageProducer можно ссылаться только один раз
Я хочу использовать шлюз в нескольких потоках. Мое определение шлюза:
@Bean
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public MarshallingWebServiceOutboundGateway myServiceGateway() {
Jaxb2Marshaller marshaller = new Jaxb2Marshaller();...
425 просмотров
schedule
07.03.2023
Ченнелинг интеграции Spring с именем компонента и именем метода
У меня есть PublishSubscribeChannel следующим образом:
@Bean(name = {"publishCha.input", "publishCha2.input"}) //2 subscribers
public MessageChannel publishAction() {
PublishSubscribeChannel ps =...
1147 просмотров
schedule
10.07.2022
Spring Integration null originalMessage в ErrorMessage
Мы действительно запутались с обработкой ошибок в Spring Integration. Мы используем Boot 2.0.2 и Kotlin.
Внутри @Transformer мы выбрасываем исключение X .
Кроме того, в определении потока Java DSL мы выбрасываем такое же исключение X ....
541 просмотров
schedule
27.07.2023
Шлюз не устанавливает заголовок replyChannel
В настоящее время я работаю над проектом, созданным с помощью Spring Integration 4.3.14, и мы решили попробовать использовать DSL, но у меня возникли проблемы с попыткой интегрировать различные подпотоки.
У меня определен следующий IntegrationFlow:...
93 просмотров
schedule
20.04.2022
Spring Integration Java DSL с использованием JMS retry / redlivery
Как я могу эффективно поддерживать повторную доставку JMS, когда обработка сообщений вызывает исключение?
У меня есть поток, использующий JMS (ActiveMQ) с connectionFactory, который настроен так, чтобы разрешить n попыток повторной доставки.
Я...
564 просмотров
schedule
17.04.2022
Spring integration - агрегатор от sftp inbound
Какое наилучшее решение для объединения одного сообщения из источника входящего сообщения sftp, содержащего несколько файлов? У нас есть на удаленной машине 3 файла, которые нужно получить. После этого мы объединяем содержимое этих файлов в одно...
52 просмотров
schedule
09.06.2022
Как динамически определить шаблон фильтра файлов для входящего адаптера SFTP Spring Integration?
Мне нужно динамически извлекать определенные файлы из разных каталогов с разных серверов sftp в каталог локального сервера приложения загрузки Spring.
Я храню пути и шаблон файла в базе данных postgres. У меня все работает, но я не знаю, как...
2893 просмотров
schedule
05.04.2023
Spring Integration Java DSL: как направить поток в канал, имя которого статично?
Как направить поток на следующий канал со статическим именем потока? Если я попробую это
@Bean
private IntegrationFlow postDataToMyChannel() {
return f -> f
...
.route("myChannel.input");
}
там идет
Caused...
135 просмотров
schedule
15.01.2024
Spring интеграция dsl-буфера
У меня есть требование, когда мне нужно хранить / буферизовать сообщения, полученные по каналу, и сохранять в базе данных в зависимости от количества сообщений или тайм-аута, что означает отсутствие сообщений в течение 1 минуты. Есть ли способ...
253 просмотров
schedule
20.03.2023
Как реализовать распределенную блокировку вокруг поллера в Spring Integration с помощью ZooKeeper
Spring Integration имеет поддержку ZooKeeper, как описано в https://docs.spring.io/spring-integration/reference/html/zookeeper.html Однако этот документ настолько расплывчатый.
Он предлагает добавить ниже bean-компонент, но не дает подробностей о...
1071 просмотров
schedule
15.05.2023
Как сделать звонок в активатор услуги транзакционным после сплита
Я использую следующее, чтобы определить свой поток интеграции:
@Bean
public IntegrationFlow pollingFlow(MessageSource<Object> jdbcMessageSource) {
return IntegrationFlows.from(jdbcMessageSource,
c ->...
149 просмотров
schedule
20.03.2023
Spring Integration Java DSL: в канале ошибок регистратора базы данных не работает
У меня есть регистратор базы данных myDatabaseLogger , который ничего не делает в errorChannel канале. Команда System.out.println работает в канале errorChannel .
Мой регистратор базы данных myDatabaseLogger работает в других потоках....
184 просмотров
schedule
20.03.2023
Spring-Integration: внешняя маршрутизация
Я хотел бы разрешить вызывающим абонентам передавать внешний уведомление о маршруте , например по публикации:
POST http://localhost:8080/transform?routing-slip=capitalize&routing-slip=lowercase
Content-Type: text/plain
camelCase
Должна...
156 просмотров
schedule
07.07.2023
Масштабируемый опросчик файлов | Интеграция Spring
Что касается весенней интеграции, как масштабировать опрос файлов по горизонтали?
Предположим, что для 5s установлено средство опроса файлов .tif , и код интеграции Spring в качестве загрузочного проекта выполняется на одном сервере....
84 просмотров
schedule
14.06.2022
Spring Integration DSL: лямбда для возврата сообщения ‹T› в методе дескриптора, например с DelegatingSessionFactory?
Мотивация: мне нужно установить threadKey для DelegatingSessionFactory, прежде чем я перенаправлюсь на исходящий шлюз Sftp и потом отключу threadKey.
В зависимости от клиента мне нужно использовать другую учетную запись пользователя Sftp. Учетные...
383 просмотров
schedule
29.05.2023
Как маршрутизировать с использованием заголовков сообщений в Spring Integration DSL Tcp
У меня есть 2 службы на стороне сервера, и я хотел бы направлять им сообщения с использованием заголовков сообщений, где удаленные клиенты помещают идентификатор службы в поле type .
Правильный ли фрагмент кода из конфигурации на стороне сервера?...
833 просмотров
schedule
06.07.2023
