Вопросы по теме 'spring-rabbit'
RabbitMQ и Camel: маршрут прерван из-за потери сообщения при восстановлении
У меня неприятная проблема с RabbitMQ и sprimg-amqp. Мне нужно отправить сообщение в очередь из внешнего процесса (класс JUnit, чтобы проверить, хорошо ли работает маршрутизация). Это мой файл camel-context.xml:
<camelContext...
1633 просмотров
schedule
28.01.2023
Как заставить компилятор запретить мне использовать любые расширения RabbitMQ AMQP?
Я планирую использовать RabbitMQ в качестве реализации AMQP в своем проекте. Но я хотел бы ограничиться использованием только спецификации AMQP и не использовать какие-либо расширения RabbitMQ для AMQP . .
Есть ли способ оставить эту проверку...
63 просмотров
schedule
11.07.2023
auto-startup = false, вызывающий выход из процесса
Мы использовали auto-startup = "true", все работает нормально. Мы использовали Controlbus для запуска / остановки адаптера. Мы должны изменить auto-startup = "false", а затем запустить адаптер с помощью шины управления. auto-startup = "false"...
144 просмотров
schedule
15.02.2023
Интеграция Spring и AMQP: как изящно обрабатывать исключения десериализации?
Я использую RabbitMQ и Spring Integration для обработки входящих сообщений JSON .
Соответствующая часть конфигурации выглядит примерно так:
<amqp:inbound-channel-adapter channel="incomingChannel" queue-names="..."...
3245 просмотров
schedule
21.09.2022
Возможно ли иметь приемник асинхронных сообщений в Spring AMQP, который обрабатывает несколько типов контента?
Я использую асинхронный приемник сообщений в Spring-AMQP для получения сообщений. В настоящее время обрабатываются только сообщения с содержимым JSON, но у меня есть требование также обрабатывать сообщения с содержимым XML. Моя текущая реализация...
1174 просмотров
schedule
03.10.2022
Контейнер Spring-AMQP RPC
Есть ли в spring-amqp контейнер, поддерживающий функцию ответа?
Я хочу создать RPC, например https://www.rabbitmq.com/tutorials/tutorial-six-java.html , но с использованием spring-amqp.
3047 просмотров
schedule
24.07.2022
Как вы можете создать RabbitMQ MessageListener, используя обмен темами с автоматически объявленными очередями?
Я использую RabbitMQ в Java, используя Spring AMQP. Я отправляю сообщения, используя тему обмена.
Я хочу использовать сообщения, используя автоматически объявленные очереди с указанным routingKey, и единственный способ, которым мне удалось...
2066 просмотров
schedule
27.10.2022
Spring RabbitTemplate не создает очередь недоставленных сообщений с TTL
Я использую spring-rabbit1.1 и RabbitMQ 3.3.1,
Моя весенняя конфигурация создаст любую очередь с помощью RabbitTemplate на Rabbit MQ, но если очередь была настроена с x-dead-letter-exchange и x-message-ttl, она просто создает очередь без TTL и...
3294 просмотров
schedule
08.10.2022
Получить аргументы и атрибуты очереди в RabbitMQ
В REST API RabbitMQ вы можете получить различную информацию о существующей очереди ( http://rabbit.example.com:15672/api/queues/ ):
{
"memory": 10888,
"messages": 0,
"messages_details": {
"rate": 0
},
"messages_ready":...
1030 просмотров
schedule
08.10.2022
Обработка тайм-аута подтверждения издателя в Spring AMQP-RabbitMQ
Я тестирую реализацию Spring RabbitMQ для AMQP и хочу использовать подтверждения издателя. Чего мне не хватает как в документации, так и в коде, так это того, как я должен обрабатывать неподтвержденные сообщения определенного возраста.
Чистая...
1652 просмотров
schedule
20.09.2022
rabbitmq-consistent-hash-exchange с java-клиентом/весенним кроликом
Я хотел бы использовать возможности rabbitmq-consistent-hash-exchange из java-клиента или, что предпочтительнее, с помощью абстракции spring spring-amqp. К сожалению, мне не удалось найти пример, который объясняет использование java и ссылается на...
965 просмотров
schedule
18.07.2023
Конфигурация RabbitMQ для нескольких очередей
По-видимому, я настроил единую очередь для получения пользовательских сообщений в своем приложении. Ниже приведена конфигурация.
<!-- Creates a queue for consumers to retrieve messages -->
<rabbit:queue name="UserPostpublishQueue"...
2851 просмотров
schedule
27.09.2023
Соединение Rabbitmq внезапно закрывается на локальном хосте
У нас возникла проблема с внезапным закрытием соединения с rabbitmq в сценарии разработки / тестирования localhost. В нашей среде разработки у нас есть rabbitmq, установленный на каждом компьютере разработчиков с Windows 7, и мы подключаемся к нему с...
3901 просмотров
schedule
03.11.2022
Как добиться параллелизма с помощью прослушивателя сообщений, не поддерживающего потоки
Ответ на этот вопрос объясняет, как использовать прототип область с <rabbit:listener-container/> в Spring AMQP, когда прослушиватель не является потокобезопасным.
Другой пользователь спросил (в комментарии), как настроить ту же среду,...
1523 просмотров
schedule
16.05.2023
spring-amqp очищает ресурсы при завершении работы контейнера прослушивателя
У меня есть несколько контейнеров сообщений с одним слушателем в каждом.
Каждый слушатель
Не является потокобезопасным
Объявлено @Scope (значение = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
Не является лицом без гражданства. имеет...
406 просмотров
schedule
19.12.2022
Как записать имя очереди в SimpleMessageListenerContainer.java
У нас возникли проблемы с одним из потребителей, и нам нужно отладить код. SimpleRabbitListenerContainerFactory позволяет установить ConsumerTagStrategy, который должен добавлять теги во время ведения журнала.
@Bean
public...
1066 просмотров
schedule
03.07.2023
SimpleMessageListenerContainer — исключение, вызванное потребителем, обработка может быть перезапущена, если фабрика соединений поддерживает это.
Я продолжаю получать следующее предупреждение на стороне потребителя spring rabbitmq. он продолжает искать перезапуск.
[SimpleAsyncTaskExecutor-3317] WARN org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised...
4647 просмотров
schedule
14.07.2023
Как реализовать потребителя очереди с циклическим перебором в Spring boot
Весной я создаю службу, управляемую сообщениями, которая будет работать в кластере и должна извлекать сообщения из очереди RabbitMQ в циклическом режиме. Реализация в настоящее время извлекает сообщения из очереди в порядке очереди, что приводит к...
2064 просмотров
schedule
30.08.2022
Как я могу полностью закрыть RabbitTemplate в Spring Rabbit?
Я написал скрипт, который использует Spring Rabbit для помещения ряда сообщений в очередь Rabbit, используя RabbitTemplate.convertAndSend , а затем завершает работу. Однако соединение Rabbit, по-видимому, поддерживает работу приложения даже после...
1146 просмотров
schedule
03.06.2023
Какой правильный тип исключения для NACK сообщения с использованием прослушивателя на основе аннотаций в spring -boot с amqp?
Я использую весеннюю загрузку с spring-amqp и прослушивателем на основе аннотаций для получения сообщения от брокера rabbitmq. У меня есть компонент Spring, который содержит такой метод:
@RabbitListener(queues = "tasks")
public void...
424 просмотров
schedule
14.03.2022
