Вопросы по теме 'spring-integration-dsl'
Как добавить собственный метод в интерфейс ftp-шлюза Spring интеграции?
После интеграции Spring ftp doc , Мне удалось отправить файлы на ftp-сервер через конфигурацию java:
@MessagingGateway
public interface MyGateway {
@Gateway(requestChannel = "toFtpChannel")
void sendToFtp(File file);
}
ss...
439 просмотров
schedule
05.10.2021
Spring Integration DSL: отправка вывода преобразования на несколько конечных точек
Унаследованный проект Spring Integration определяет рабочий процесс с помощью XML. Базовый поток выглядит следующим образом:
int-jms:message-driven-channel-adapter ожидает сообщения и помещает его во внутренний канал.
Трансформатор...
2585 просмотров
schedule
05.11.2021
Как объединить сообщения из канала очереди с помощью Spring Integration DSL?
я определяю канал очереди
@Bean("mail-action-laundry-list-channel")
public MessageChannel mailRecipientActionMessageChannel() {
return new QueueChannel(20);
}
В приведенном ниже потоке я буду добавлять сообщения из канала очереди, я...
756 просмотров
schedule
29.10.2021
Отправка сообщения с помощью Spring Integration в тему ActiveMQ Artemis
Цель
Я хочу отправить сообщение в тему, которую я обработаю позже с помощью клиентских приложений. Для этой цели я использую Spring Boot и Spring Integration Java DSL с его модулем JMS. В качестве брокера сообщений я использую собственный...
1578 просмотров
schedule
11.11.2021
Spring Integration Гарантированная доставка сообщений JMS с использованием DSL
Я пытаюсь создать поток (1), в котором сообщение получено от адаптера TCP, который может быть клиентом или сервером, и он отправляет сообщение брокеру ActiveMQ.
Мой другой поток (2) выбирает сообщение из требуемой очереди и отправляет по назначению...
506 просмотров
schedule
18.09.2021
Как я могу сопоставить входящие заголовки как String вместо byte [] в моем проекте Spring Cloud Stream?
У меня есть простой проект Spring Cloud Stream, использующий потоки Spring Integration DSL и связующее устройство Kafka. Все работает отлично, но значения заголовков сообщений, поступающие от Kafka, приходят как byte[] .
Это означает, что мои...
1709 просмотров
schedule
12.11.2021
Ошибка Spring интеграции java dsl Обнаружен неоднозначный тип параметра
Я новичок в весенней интеграции dsl.
В рамках обучения я преобразовал один XML на основе конфигурации Java DSL.
Вот ссылка для конфигурации xml.
https://dzone.com/articles/spring-integration-building .
Вот моя конфигурация Java DSL....
735 просмотров
schedule
24.10.2021
Добавить весеннюю интеграцию хранилища сообщений dsl
В настоящее время я рассматриваю варианты добавления отслеживания всех сообщений в моем приложении в реальном времени.
Я включил историю сообщений , так что технически я получу все шаги, произошедшие во время потока.
Теперь я хочу сохранять...
98 просмотров
schedule
22.09.2021
Ошибка Spring Integration Java DSL
Я создал новый проект Spring Boot + Spring Integration + Spring Integration Java DSL, используя последние доступные версии. Проект создается нормально, но когда я запускаю приложение, я получаю:
Caused by: java.lang.NoSuchMethodError:...
3400 просмотров
schedule
22.02.2022
Интеграция Spring - добавление информации в фильтр с помощью XmlValidatingMessageSelector DSL
Лучше объясни.
Я хочу проверить xml в DSL, который применяет тот или иной xsd в зависимости от одного из полей xml.
А сейчас выглядят так:
Прочитать из MongoDB -> Разделить файлы JSON -> попытаться проверить. Но я хочу передать в качестве...
80 просмотров
schedule
24.02.2022
DSL интеграции Spring - CharacterStreamWritingMessageHandler
Я пишу образец кода для примера basic-amqp ( https://github.com/spring-projects/spring-integration-samples/blob/master/basic/amqp/src/main/resources/META-INF/spring/integration/spring-integration-context.xml ) в DSL
@Bean
public IntegrationFlow...
37 просмотров
schedule
01.03.2022
Припаркуйте XML-сообщение в недопустимом формате в очередь на парковку AMQP
Учитывая, что у меня есть IntegrationFlow
IntegrationFlows.from(
Amqp.inboundAdapter(rabbitConnectionFactory, QUEUE)
.messageConverter(new MarshallingMessageConverter(xmlMarshaller))...
86 просмотров
schedule
02.03.2022
Spring Integration Java DSL IntegrationFlow as Gateway не запускается
Я использую стандартный Spring @RestController внутри приложения Spring Boot, которое вызывает Spring Integration, чтобы инициировать поток сообщений. Насколько я понимаю, крючком для Spring Integration в этом случае является использование шлюза -...
941 просмотров
schedule
21.03.2022
Spring интеграция DSL :: проблема при вызове канала из xml
Я сделал один простой DSL, который извлекает данные из базы данных и выполняет простое преобразование в активаторе службы.
@Bean
public IntegrationFlow mainFlow() {
return IntegrationFlows.from("userChannel")...
356 просмотров
schedule
29.03.2022
Используйте Spring Integration DSL для чтения из раздела Tibco EMS
Я пытался настроить весеннюю интеграцию dsl для чтения из темы Tibco EMS, выполнить некоторую обработку полученного сообщения, а затем отправить его в очередь ActiveMQ. Мне удалось успешно настроить это с помощью конфигурации XML, но вместо этого я...
647 просмотров
schedule
10.04.2022
Может ли SpEL в Spring Integration Router использовать методы класса String Java
Это дополнительный вопрос к Как использовать SpEL для чтения полезной нагрузки и содержимого заголовка в Spring Integration Router
Технологии в моем проекте
Spring Boot 2
Spring Integration (XML style)
Java 8
Tomcat 9.x/Liberty 19.0.0.1...
306 просмотров
schedule
11.04.2022
Spring Integration Java DSL: непрерывно создавайте и уничтожайте потоки интеграции
Мои потоки настроены в базе данных, и моя программа постоянно создает и уничтожает потоки.
Таким образом, конфигурации потока (например, конфигурация cron) могут быть изменены в любое время.
Потоки регистрируются методом...
227 просмотров
schedule
16.04.2022
Установить ответ Http: InboundGateway StatusCode в Spring Integration Java DSL
Следующий фрагмент конфигурации принимает HTTP POST с телом запроса JSON для создаваемого экземпляра User, но мне страшно, если я смогу заставить его вернуть 201 Created . Любые идеи?
@Bean
public IntegrationFlow flow(UserService userService) {...
1012 просмотров
schedule
26.04.2022
Как добавить Spring Boot HealthIndicator в приемник Imap IntegrationFlow
Как интегрировать Spring Boot HealthIndicator с электронной почтой для опроса IntegrationFlow с imap?
Я могу получить исключения из IntegrationFlow через errorChannel, но как мне очистить исключение после того, как IntegrationFlow снова начнет...
24 просмотров
schedule
06.05.2022
Аннотация заголовка с расширением. в имени заголовка, например @Header (foo.bar), не сопоставляется
У меня есть простая конечная точка сообщения Spring Integration с подписью:
@Transformer
String handleMessage(@Payload String payload, @Header("nerf") String nerf, @Header("foo.bar") String foobar) {
//...
}
Переменная nerf всегда...
61 просмотров
schedule
16.05.2022
