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

Мне не удалось найти простой пример для модульного тестирования dsl интеграции Spring, который включает в себя получение сообщения из очереди и выполнение вызова отдыха. Я просмотрел примеры...

Я пытаюсь протестировать простой прослушиватель MQTT, созданный с помощью Spring Boot и Spring Integration, но он не работает. Я пробовал много подходов. Наиболее перспективным было: @RunWith(SpringRunner.class) @SpringBootTest public class...

Почему канал может быть установлен на TcpReceivingChannelAdapter , входящем адаптере, но не на TcpSendingMessageHandler , исходящем адаптере? Почему исходящий адаптер называется TcpSendingMessageHandler, почему обработчик , а не адаптер?...

Я пытаюсь создать адаптер входящего канала для прослушивания темы JMS, которая находится во внешней системе JMS. Все примеры, которые я нашел, были выполнены в XML, а не с использованием Spring DSL. Кто-нибудь из вас делал это раньше, и если да, то...

Я использую приведенный ниже код в приложении Springboot: @Bean public IntegrationFlow mailListener() { return IntegrationFlows.from(Mail.imapInboundAdapter(receiver()), e ->...

Мне интересно, как предотвратить одновременное использование одними и теми же файлами нескольких экземпляров определенного потока интеграции DSL. Я использую FileReadingMessageSource в начале потока, так что в данном случае это мой наблюдатель за...

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