Описание тега spring-integration-dsl
1
ответ
Подключение двух каналов очереди, поддерживаемых JDBC Store в Spring Intgegration DSL
Я пытаюсь соединить два канала очереди (при поддержке JDBC Store). @Configuration public class DemoIntegration { @Bean public IntegrationFlow flow(MessageChannel firstJDBCChannel, MessageChannel secondJDBCChannel) { return IntegrationFlows.from(firs…
09 дек '17 в 08:59
0
ответов
Специальные символы в сообщении потребляют Spring-интеграции-AWS
Мы отправляем сообщение в поток kinesis из приложения интеграции с пружиной, но при использовании сообщения через @StreamListener из приложения связывания kinesis мы получаем специальные символы, такие как "f t foo". Пожалуйста, найдите ниже фрагмен…
13 мар '18 в 12:04
1
ответ
Как реализовать входящую и исходящую конфигурацию JMS в отдельном приложении Spring интеграции?
Мой пример использования - внедрение сервиса уведомлений в нашем проекте. Мы использовали пружину с jms, и она отлично работает с другими службами. Возможность отправки сообщения в очередь из одного приложения и получения сообщения из очереди в друг…
22 июн '18 в 05:38
1
ответ
Входящий адаптер JDBC, получающий только одну запись, а не все
Я использую следующий входящий адаптер JDBC, который получает сообщение. Есть еще один активатор, который контролирует канал и вызывает метод. Однако проблема в том, что активатор службы получает только одно "событие", а не все. Но запрос должен "вы…
05 дек '18 в 21:15
1
ответ
Spring Integration ошибка придает завершенную полезную нагрузку
У меня есть слушатель JMS. После прочтения сообщения я преобразую его в свой объект public IntegrationFlow queueProcessorFlow() { return IntegrationFlows.from(Jms.inboundAdapter(jmsTemplate) .destination("test_queue"), c -> c.poller(Pollers.fixed…
03 дек '18 в 14:46
1
ответ
Каков предпочтительный способ указания преобразователя для ответа исходящего шлюза с использованием DSL
У меня есть следующий кусок кода: @Configuration @EnableConfigurationProperties(ISOGatewayProperties::class) class ISOGatewayConfig { @Bean fun isoGatewayFlow( isoProps: ISOGatewayProperties, isoTransformer: ISOTransformer) : IntegrationFlow = Integ…
27 авг '18 в 18:46
1
ответ
При получении сообщения MessageDeliveryException: у Диспетчера нет подписчиков
ОБНОВЛЕНИЕ: После перехода от класса Tcp() к классу держателей к классу конечных точек все снова заработало, теперь я озадачен, почему это работает даже сейчас, потому что для меня это не имеет смысла, почему это работает После некоторых головных бо…
22 июн '18 в 11:19
1
ответ
Интеграция Spring MessagePublishingErrorHandler не вызывается
Я пытаюсь опубликовать свои исключения в определенном канале ошибки. Я использую MessagePublishingErrorHandler для того же. Но мои ошибки не направляются на канал, который я создаю. Вот мой код: - Канал: - @Bean(value = "appErrorChannel") public Pub…
17 май '18 в 12:19
1
ответ
Весенняя интеграция dsl - NoSuchBeanDefinitionException
У меня есть поток с шлюзом jpa, где я хочу получить данные и перейти к другому. Но я получаю исключение: org.springframework.beans.factory.NoSuchBeanDefinitionException: недоступен компонент с именем estatement.move-to-cezar ОБНОВИТЬ Контроллер Отды…
20 июн '18 в 09:24
1
ответ
Обработка исключений Spring-Integration Webflux
Если исключение происходит в потоке webflux-интеграции с пружиной, само исключение (с помощью stacktrace) отправляется вызывающей стороне в качестве полезной нагрузки через MessagePublishingErrorHandler, который использует канал ошибок из заголовка …
06 окт '18 в 08:11
1
ответ
MarshallingWebServiceOutboundGateway занимает слишком много для первого запроса
У нас есть много мыльных сервисов, которые мы используем для подключения, и каждый раз, когда первому тому же сервису требуется интеграция, а последующие запросы быстро сокращаются на 60% времени ответа. Проанализировано на инициализацию привязок JA…
08 окт '18 в 20:00
0
ответов
Как фильтровать электронные письма по теме при опросе в Spring Integration
Я хотел бы опросить электронные письма, основанные на теме. Если мы хотим опросить электронные письма с темой "Тест", приведенный ниже код извлекает все электронные письма. Но нам нужно отфильтровать письма с темой "Тест". Как я могу фильтровать по …
20 сен '17 в 21:31
1
ответ
Настройте подпоток в качестве компонента для PublishSubscribeChannel в DSL интеграции Spring
В соответствии с разделом " Поддержка подпотоков" данного руководства, можно было бы ожидать, что можно будет настроить подпоток очень просто: используя фабрики DSL или лямбды. // This is modified example from the guide. @Bean public IntegrationFlow…
25 авг '17 в 12:56
1
ответ
Динамический TCP-сервер с Spring Integration с использованием Java DSL
Я пытаюсь создать TCP-сервер и клиент, читая файлы свойств, которые содержат детали соединений. Я использую динамические потоки и потоки интеграции во время выполнения с помощью следующего справочного документа ( 9.20 Динамические потоки и потоки ин…
11 апр '18 в 15:02
1
ответ
Пружинная интеграция потока Poller исчерпана
Я использую String Integration DSL для получения почты с почтового сервера POP3s. Через несколько часов я вижу, что программа опроса перестает опрашивать почтовый сервер и не обрабатывает электронную почту. Я могу войти на почтовый сервер и увидеть,…
24 ноя '17 в 07:05
1
ответ
Преобразование прослушивания из синтаксиса XML в аннотацию Spring Integration Java или DSL
Я нашел так много разных способов преобразования моих регистраторов прослушиваний в конфигурацию Java, но ни один из них, похоже, не работает. Вот моя версия XML: <int:channel id="tasksRequestChannel"> <int:queue capacity="${channel.queue.c…
20 авг '18 в 22:14
1
ответ
Как проверить IntegrationFlow с помощью FileReadingMessageSource и HttpRequestExecutingMessageHandler в весенней интеграции
У меня есть поток интеграции для опроса файлов json из некоторой папки и отправки их в конечную точку http отдыха. Ниже мой код: @Bean public IntegrationFlow jsonFileToRestFlow() { return IntegrationFlows .from("fileInputChannel") .transform(new Fil…
16 июл '18 в 11:09
1
ответ
Spring Integrtation и Spring Cloud Stream
Я пишу заявление, которое Опрашивает каталог (Sprint Integration DSL поток) Как только файл будет доступен, он будет помещен в очередь rabbitmq Микросервис прослушивает поток RabbitMQ и обрабатывает файл (это написано в потоке Spring Cloud) Теперь я…
03 окт '18 в 14:46
1
ответ
Spring Integration: интеграция REST в JMS дает ошибку времени ожидания
Привет я пытаюсь реализовать следующий поток с помощью Spring Integration. Предоставьте сервис REST, управляйте полезной нагрузкой, запишите измененную полезную нагрузку в JMS и ответьте на сервис REST. @Bean public IntegrationFlow httpInputFlow() {…
29 июн '17 в 12:04
1
ответ
Динамическая генерация TCP-клиента с входящим каналом и ответным каналом
Я новичок в интеграции Spring. Работа с Spring 4, только java аннотации. В проекте, в котором я сейчас работаю, мы установили tcp-соединение в файле свойств. На данный момент он жестко запрограммирован только на 2 разных соединения, и его необходимо…
15 июн '18 в 10:52