Результаты поиска по запросу "spring-integration"
Вместо использования isRegisteredWithDestination () я использую это условие «amqBroker.getRegionBroker (). GetDestinationMap (). ContainsKey (myTopic)», которое, кажется, работает. amqBroker - это компонент BrokerService.
я есть тест интеграции для моей конфигурации Spring Integration, который использует сообщения из темы JMS с длительной подпиской. Для тестирования я использу...
С помощью адаптера IMAP Spring, как получить письмо, помеченное как «непрочитанное» вручную?
У меня есть фрагмент кода, который использует IMAP-адаптер Spring интеграции для опроса входящих сообщений, чтобы прочитать все входящие электронные письма, которые непрочитаны и которые работают отлично. Но если я открою какое-либо сообщение ...
, Мы наконец добрались до сути проблемы! Спасибо! Вы, ребята, делаете потрясающую работу на этой основе!
я есть вопрос, очень похожий на этотКак создать Spring Reactor Flux из очереди ActiveMQ? [https://stackoverflow.com/questions/43126775/how-to-create-a-spring-reactor-flux-from-a-activemq-queue] С одним отличием, что сообщения приходят из ...
Имеет ли значение, если вы не можете отправить результат преобразования в AMQP?
ичок в весенней интеграции и не понимаю, как отправлять сообщения об ошибках в назначенную очередь ошибок. Я хочу, чтобы сообщение об ошибке было заголовком исходного сообщения и попадало в отдельную очередь. Я прочитал, что это можно сделать с ...
Спасибо! Я реализовал часть запроса на подключение клиента, используя собственный сериализатор / десериализатор. Работа над ответной частью клиента. Большое спасибо за указатели. Будет просить больше помощи, если это необходимо!
ледовал заэто [https://github.com/spring-projects/spring-integration-samples/tree/master/basic/tcp-client-server] пример настройки TCP-клиента в Spring. Ниже мойtcpClientServerDemo-context.xml файл, где лежит трансформатор. Может ли кто-нибудь ...
Это должен быть принятый ответ.
ичок в партии Spring и не мог понять, как это сделать .. В основном у меня есть весенний файл-поллер, который запускается каждые N минут, чтобы искать файлы с некоторым именем (например, A.txt & B.txt) в определенном каталоге. В любой момент ...
Оно работает! Я должен был вставить «причина». в начале выражения, потому что вокруг HttpServerErrorException есть оболочка MessageHandlingException, но я смог убедиться, что 500-ые произошли сбой сразу, а 503-е были повторены. Спасибо Артему и Гэри за объяснения. Это, без сомнения, будет намного более гладким в будущем выпуске SI.
я есть вызов шлюза http, который иногда возвращает 503 ошибки. Я хотел бы настроитьповторить совет [https://docs.spring.io/spring-integration/reference/htmlsingle/#advice-classes] вокруг этого вызова, но я не хочу делать это для каждой ошибки, ...
Смотрите также мой ответ.
работал асинхронные службы Spring Cloud Stream и пытаюсь разработать пограничный сервис, который использует @MessagingGateway для обеспечения синхронного доступа к асинхронным службам по своей природе. В настоящее время я получаю следующую ...
Я нашел недостающие пакеты, и теперь мне удалось заставить его работать. Еще раз спасибо Отмечен как правильный ответ.
аюсь построить модуль для развертывания на нескольких узлах, используя загрузку Spring. Из-за временных ограничений конкретного приложения я вынужден использовать UDP и не могу полагаться на более простые в использовании средства REST, которые ...
Spring Integration - программно создавать / разрывать каналы
Можно ли программно создавать / отключать каналы Spring Integration, а не объявлять их статически в конфигурации Spring? Моя ситуация такова: У меня есть веб-приложение, требующее push-уведомлений, поэтому я использую длинные опросы. Эти ...