Описание тега spring-integration

Используйте этот тег для вопросов о проекте Spring Integration. Он не предназначен для ответов на общие вопросы об интеграции других проектов Spring с другими технологиями.
1 ответ

inbound-channel-adapter - Как обновить поле строки при сбое?

У меня есть интеграция, которая начинается со стандартного запроса к базе данных, и она обновляет состояние в базе данных, чтобы указать, что интеграция работает нормально. Оно работает. Но если данные не могут быть обработаны и возникла исключитель…
15 май '14 в 10:21
1 ответ

Адаптер JMS запустить два потребителя JMS

У меня проблема с int-jms:inbound-channel-adapter, когда я запускаю свое приложение, я вижу в activemq webadmin, что у меня есть два потребителя для очереди. <int-jms:inbound-channel-adapter id="jmsAdapter" acknowledge="transacted" destination-na…
12 май '15 в 08:44
1 ответ

TcpSendingMessageHandler с совместной работой TcpReceivingChannelAdapter

В Spring Integration я использую пару канальных адаптеров для отправки / получения сообщений от сокета сервера. Я всегда создаю клиентские соединения со следующими адаптерами: @Bean public TcpReceivingChannelAdapter tcpIn(AbstractClientConnectionFac…
05 окт '16 в 10:56
1 ответ

Поток JBoss WorkManager в состоянии БЛОКИРОВАН

Мы используем JBoss 5 и JDK 1.6. Мы используем интеграцию Spring для опроса файлов из нескольких каталогов. <file:inbound-channel-adapter id="flowInboundFileAdapter" directory="${service.integration.path}" scanner="recursiveScanner" filter="custo…
07 мар '16 в 06:37
1 ответ

Маршрутизация выходного канала

Я пытаюсь переписать поток Spring Integration с XML на Java. Я хотел бы направить данные, отправленные по каналу: @Bean(name = "sendData") public MessageChannel getSendData() { return MessageChannels.direct() .get(); } на два других канала: @Bean(na…
1 ответ

Как получить имя пользователя ws-security в заголовок сообщения Spring Integration

Я довольно новичок в Spring Integration. Как получить токен имени пользователя ws-security в заголовок Spring Integration. Я понимаю, как добавить Wss4jSecurityInterceptor для проверки имени пользователя, но так как это перехватчик, у меня нет досту…
22 июл '14 в 19:36
2 ответа

Инжекция пружинной зависимости во внешнюю банку

У меня есть проект А, который потребляет банку, скажем, B.jar (где B - другой проект, используемый в качестве зависимости в нашем проекте A), теперь есть Bean (вид Spring-gemfire кеш), который содержит все необходимые данные на карте. Этот бин карты…
1 ответ

Интеграция Spring: тестирование логики, зависимой от poller

Интересно, как я могу написать весенние тесты для утверждения логической цепочки, которая запускается SourcePollingChannelAdapter. Что приходит мне в голову: используйте Thread.sleep(), который действительно плохая идея для тестов Иметь другую тесто…
15 дек '17 в 13:12
1 ответ

Весенняя интеграция с примером RedisLockRegistry

Мы реализуем поток, где <int-sftp:inbound-streaming-channel-adapter/> опрашивает каталог для файла и при обнаружении передает поток активатору службы. Проблема в том, что у нас будет запущено несколько экземпляров приложения, и мы хотели бы за…
1 ответ

Spring-интеграция: настраиваемое имя @Header-параметра?

Я использую Spring-integration для прослушивания очередей, и теперь я столкнулся с довольно глупой ошибкой. Оказывается, что имя параметра сообщения было написано с ошибкой, что привело к ошибкам во время выполнения. Чтобы это исправить, мне нужно п…
01 июл '15 в 13:43
1 ответ

Как записывать время, затрачиваемое компонентами jdbc

В моем весеннем интеграционном приложении у меня есть несколько хранимых-процедур-исходящих-шлюзов, я бы регистрировал, сколько времени занимает каждый вызов, любая помощь будет оценена. В идеале я хотел бы иметь возможность включать / отключать вед…
11 фев '15 в 16:50
1 ответ

Как перехватить исключения сокетов на TcpInboundGateway?

Я использую TcpInboundGateway от spring-integration для socket клиент. В TcpInboundGateway.doOnMessage() поток отправляется через сокетное соединение. Если возникает исключение, например, из-за того, что сокет закрыт, существует просто журнал ошибок…
16 июн '15 в 16:45
1 ответ

Использование тернарного оператора в Spring-Integration xpath-expression

Я использую Spring Integration и у меня есть следующие два вида ввода XML Первый XML: <businessArea>SomeValue</businessArea> Второй XML: <?xml version="1.0" encoding="UTF-8"?> <businessArea> <Code>SomeValue</Code>…
25 июл '14 в 07:47
1 ответ

Не удалось создать экземпляр компонента: вложенное исключение - java.lang.VerifyError: ошибка StackMapTable: неправильное смещение

Пока я запускаю свое приложение на новом сервере с Java7 и сталкиваюсь с ошибками / предупреждениями ниже. Тот же код работал на другом сервере, и это работает нормально. WARN : 11/Feb/2016 10:54:47,685 [P=86614:O=0:CT] ctory.support.DefaultListable…
11 фев '16 в 12:29
1 ответ

Подключение двух каналов очереди, поддерживаемых JDBC Store в Spring Intgegration DSL

Я пытаюсь соединить два канала очереди (при поддержке JDBC Store). @Configuration public class DemoIntegration { @Bean public IntegrationFlow flow(MessageChannel firstJDBCChannel, MessageChannel secondJDBCChannel) { return IntegrationFlows.from(firs…
1 ответ

Spring Integration: как отправить байтовый массив как параметр POST с помощью http:outbound-gateway?

Я хочу отправить экземпляр объекта, сериализованный как byte[] для int-http:outbound-gateway в качестве параметра HTTP POST. Вот моя конфигурация интеграции Spring: <int:chain input-channel="requestChannel" output-channel="replyChannel"> <i…
21 июл '16 в 09:01
1 ответ

Используйте функциональность @RequestMapping (сопоставление метода URL с Java) без HTTP-запроса / сервлета

Я пытаюсь создать простой PoC для замены приложения, которое в настоящее время использует файлы JAR, загруженные в основное веб-приложение Java (Spring MVC 4.2), для объявления дополнительных контроллеров при запуске. Это выглядит примерно так: Clie…
08 окт '15 в 09:26
1 ответ

Start & Stop - Spring-адаптер входящего канала imap из основных аргументов

Я настроил адаптер канала imap для получения почты с фиксированной задержкой 20000. Так что работает как положено. Но проблема в том, что он работает постоянно. Итак, у меня есть пара вопросов: Как я могу запустить и остановить этот адаптер канала, …
06 июл '16 в 17:18
1 ответ

Может кто-нибудь объяснить, как использовать Recipient в Spring Integration

Я пытаюсь использовать Spring Integration для отправки электронной почты. Я просмотрел несколько книг и в Интернете, но я не раскрыл, как создать или использовать получателя. Этот учебник для отправки http://gordondickens.com/wordpress/2010/08/09/se…
12 мар '14 в 15:14
1 ответ

Помещение вывода из средства записи элементов Spring Batch в канал сообщений Spring Integration

Каков наилучший способ получения выходных данных от средства записи элементов Spring Batch - очевидно, запускаемого как часть задания - и помещения его в канал сообщений Spring Integration? Я понимаю, что одним из вариантов является кодирование слуш…
21 янв '14 в 07:53