Я развернул поток с дескриптором развертывания «module.*.count=0», чтобы принудительно выполнить прямую привязку. При использовании rabbitmq-trace сообщения проходят через кролика, однако я вижу меньше сообщений, чем если бы опция прямой привязки...

Я пытаюсь создать Spring XD ( Spring Integration DSL ) модуль приемника с использованием spring-integration-aws расширение. Мой модуль выглядит так: @Configuration @EnableIntegration public class S3Module {...

Вот чего я пытаюсь достичь: Сервер пакетных заданий, который обеспечивает унифицированную точку входа для заданий моих приложений и централизованное место для выполнения заданий, построенное поверх Spring Batch. Различные приложения могут...

Допустим, мои входящие данные представляют собой объект json или массив объектов json. Я хочу разделить входящие данные json, если это массив, чтобы я мог вставить их в коллекцию MongoDB (для простоты давайте пока просто войдем в консоль)....

У меня есть поток Spring XD, который содержит различные модули и DLQ, включенные для потока, который я не могу удалить, поскольку это необходимо для сценария повторной попытки клиента http в потоке. В одном из процессоров я выбрасываю исключение и не...

Добрый вечер всем Я использую SpringXD-1.3.0.RELEASE (конфигурация: 3 администратора и 3 контейнера) и RabbitMQ 3.5.7 (3 узла) в следующем сценарии: stream create --name fire --definition "time --timeUnit=MILLISECONDS > topic:fire"...

Если я попытаюсь использовать bean-компонент истории сообщений из Spring Integration "int:message-history" при разработке модуля Spring XD, это приведет к сбою при попытке экспортировать bean-компонент JMX. Я видел, что используется стратегия...

Я нахожу ниже наблюдения весной xd У меня есть поток, как показано ниже s3-source| processor-parser|http-client1|Request-construct-processor>queue queue > processor|http-client2|processor|http-client3>queue Когда мой http-клиент...

Я столкнулся с этой проблемой при сохранении данных из очереди ESB JMS в HDFS в avro с помощью springxd. Я создал собственный процессор для анализа входящего xml из очереди JMS, преобразования в avro и сохранения в HDFS с использованием потока...

Я пытаюсь создать поток Spring XD, который принимает счетчик значения поля строки json. Строка Json отправляется в сообщении через очередь RabbitMQ с заголовком Content-Type приложения/json. Spring XD регистрирует сообщение (строка Json) и...

java.lang.NoClassDefFoundError: com/sap/conn/jco/JCoException at testSAP.TestSAP.execute(TestSAP.java:41) ~[na:na] at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.doInTransaction(TaskletStep.java:406)...

У меня есть модуль http-процессора spring-xd с http-outbound-gateway, который имеет errorChannel и outputChannel. Любое сообщение с HTTP 200 приходит в outputChannel, а остальные попадают в failureChannel. Прямо сейчас модуль http-процессора...