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

Вопросы с тегом
1 ответ

Spring Integration AMQP ConcurrentModificationException

Мы используем ThreadPoolTaskExecutor для распараллеливания выполнения обработчика сообщений, но мы сталкиваемся с исключением одновременной модификации. Ниже приведено исключение: 2018-07-26 21:18:15.563 ERROR [dia-feed-sftp,a889a5984eb10d70,3a48689…
27 июл '18 в 15:01
1 ответ

Spring Integration: TaskExecutor и MaxConcurrentConsumers в AmqpInboundChannelAdapter

Приложение My Spring Integration использует сообщения из RabbitMQ, преобразует их в сообщение SOAP и выполняет запрос веб-службы. Можно получить много (10 - 50) сообщений в секунду из очереди. Или после перезапуска приложения в очереди RabbitMQ може…
28 авг '18 в 20:16
1 ответ

Как использовать все сообщения, необходимые в Spring IntegrationFlow, когда число сообщений превышает число одновременных потребителей?

У меня есть поток интеграции, определенный следующим образом: IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "queueName") .id("id") .autoStartup(autoStartup) .concurrentConsumers(2) .maxConcurrentConsumers(3) .messageConverter(messageC…
05 дек '17 в 11:01
1 ответ

Почему AmqpChannelFactoryBean с Jackson2JsonMessageConverter не является типом хранилища?

Я пытаюсь использовать интеграцию Spring с RabbitMQ, используя поддерживаемые RabbitMQ каналы интеграции Spring. (Что кажется почти не задокументированным по какой-то причине, это новое?). Для этого, кажется, я могу использовать AmqpChannelFactoryBe…
10 окт '17 в 07:48
1 ответ

SimpleMessageListenerContainer shutdowntimeoutout

Я использую spring-rabbit-1.7.3.RELEASE.jar Я определил SimpleMessageListenerContainer в моем XML с параметром shutdownTimeout. bean id="aContainer" class="org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer"> <property nam…
18 янв '18 в 19:08
0 ответов

Spring amqp throwing Listener не зарегистрирован, когда подтверждение публикации включено при втором вызове

Я пытался получить издателя Spring RabbitMQ с включенным подтверждением издателя. Первые вызовы проходят нормально и подтверждают обратный вызов. со второго вызова и далее происходит сбой со следующим сообщением об ошибке javax.servlet.ServletExcept…
08 июл '18 в 15:21
0 ответов

Spring Integration AMQP отвечает с помощью DirectExchnage

У меня есть некоторый клиентский код, который вызывает Spring Integration через вызов DirectExchange, например Map<String, Object> result = (Map<String, Object>) rabbitTemplate.convertSendAndReceive("rpc", "KEY", map); Я вижу, что поток …
06 июн '17 в 22:51
1 ответ

Как активировать функциональность после того, как попытки повторной попытки RabbitMQ закончатся? (Spring Integration - RabbitMQ Listener)

Я хочу инициировать электронную почту после того, как повторные попытки RabbitMQ Listener закончились, и все еще, если процесс обработки не удался. логика повтора работает с приведенным ниже кодом. Но как активировать функциональность (триггер элект…
27 июн '18 в 18:21
1 ответ

Одновременные потребители в контексте весенней интеграции

В приложении Spring для интеграции я использую одновременных потребителей для одновременного использования и обработки нескольких сообщений. В моем приложении я настроил все bean-компоненты на одноэлементный. Я предполагаю, что если я собираюсь расп…
26 фев '18 в 13:22
1 ответ

Spring Cloud Contract - заглушка-заглушка для обмена сообщениями с использованием AmqpInboundChannelAdapterSpec

Я пытался интегрировать модуль обмена сообщениями Stub Runner Spring Cloud Contract Verifier с Spring AMQP. я создал SimpleMessageListenerContainer с MessageListener и работает нормально. Но у меня есть другой подход. Я использую поддержку AMQP для …
06 ноя '18 в 09:53
1 ответ

Как подключить входящий адаптер AWS SQS к каналу сообщений с поддержкой AMQP?

Я успешно настроил через Java адаптер входящего канала для AWS SQS, используя прямой канал. Этот проект использует комбинацию JDBC и RabbitMQ с SQS в качестве входящего потока для 3 отдельных очередей. Мне нужны надежные сообщения, поэтому я пытаюсь…
12 янв '19 в 00:32
1 ответ

Как вручную подтвердить сообщения RabbitMQ в Spring Cloud Stream?

Для потоковых служб я хочу, чтобы сообщение оставалось в очереди, когда базовая служба вызывается в @StreamListener выходит из строя. Для этого я понимаю, что единственный способ сделать это - настроить spring.cloud.stream.bindings.channel_name.cons…
10 янв '18 в 23:26
0 ответов

spring-gration v 3.0.8.RELEASE вводит запрос jdbc в шаблон RabbitTemplate amqp с помощью команды подтверждения ack - подтверждение происходит дважды

Это конфигурация: The intended flow is: 1. Select records from table that have a certain status 2. Mark them as in progress 3. The record is used to create a RabbitMQ message using RabbitTemplate with confirm ack. 4. When message is acked, update st…
07 авг '18 в 16:02
1 ответ

Как объявить два исходящих канала-адаптера для публикации разных сообщений

Я объявил int: цепочку с одним входным и выходным каналом, <int:chain input-channel="InputChannel" output-channel="Channel"> <int:transformer method = "transform" > <bean class="com.sampleconverter" /> </int:transformer> <…
26 июл '17 в 08:14
1 ответ

Исходящий шлюз RabbitMQ с использованием конфигурации Java

Любой пример ссылки на исходящий шлюз RabbitMQ для отправки сообщений в кластер rabbitmq, я ищу настройки Java с Spring Boot
27 авг '18 в 20:42
1 ответ

Тайм-аут интеграции весенней партии в RemoteChunking

Я пытаюсь настроить задачу RemoteChunking, используя Spring Boot, Spring Batch и Spring Integrations. Я настроил activeMQ Сервер и я начинаем настраивать Spring Batch, следуя официальным документам https://docs.spring.io/spring-batch/4.0.x/reference…
17 сен '18 в 11:37
1 ответ

Извлечь подробности сообщения в Spring RecoveryCallback

Я публикую сообщения в RabbitMQ, и я хотел бы отслеживать ошибки, когда RabbitMQ не работает, для этого я добавил один RetryTemplate с обратным вызовом восстановления, но обратный вызов восстановления обеспечивает только этот метод getLastThrowable(…
26 июл '17 в 22:21
1 ответ

Как поместить сообщение в очередь в формате json, используя Spring Integration AMQP

В настоящее время я пытаюсь поместить сообщение в очередь в формате json. Ниже приведен мой фрагмент кода, но он не работает. return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, NOTE_INCOMING_QUEUE) .concurrentConsumers(2)) .transfor…
19 май '17 в 07:21
1 ответ

Эквивалентный Java Config для весенних сообщений xml config

Я пытаюсь реализовать весенний пакетный удаленный фрагмент с использованием rabbitMQ. Я по этой ссылке каковы эквивалентные конфигурации Java для этого <int:channel id="requests"/> <int:channel id="replies"/> <int-jms:message-driven-c…
15 ноя '17 в 11:49
0 ответов

int-amqp: таймаут выключения входящего канала-адаптера не работает

В моем микросервисе определена следующая конфигурация. <rabbit:queue id="queue1" name="queue1" /> <int-amqp:outbound-channel-adapter id="outboundExchange" channel ="dp-file-path-channel" amqp-template="rabbitTemplate" exchange-name="dp-rece…
12 янв '18 в 21:26