Глядя на исходный код для класса org.springframework.amqp.rabbit.listener
Я опубликовал 50К объектов в определенную очередь.У меня есть один слушатель, который выбирает...
Я играю с SimpleMessageListenerContainer, который подписан на 3 разные очереди
Чтобы создать SimpleMessageListenerContainer, я делаю что-то вроде этого. SimpleMessageConsumer...
Как я могу преобразовать следующий код с помощью среды Spring? ConnectionFactory factory = new...
Я получаю следующую ошибку для приложения rabbitmq . org.springframework.amqp.rabbit.listener
Допустим, у меня есть заявленный слушатель: Listener.java @RabbitListener(id = "test listener...
У меня проблема с получением сообщения от слушателя к издателю.Я получаю **...
Я определил очередь - blah.queue и определил для нее мертвую букву-ключ маршрутизации.Тем не менее,...
У меня следующий код, поэтому я читаю сообщения из одной очереди и пересылаю ее в другую. Меня...
У меня есть приложение springboot, которое подключается к очереди RabbitMQ, куда я отправляю...
Мои настройки У меня есть ситуация, когда я отправляю около 15 сообщений в цикле с одного...
Я хочу прослушивать сообщения, поступающие в очередь Rabbit, со слушателем Spring Rabbit.Мой класс...
Я использую библиотеку spring-rabbit-1.7.1 для пользователя rabbitmq в java.У меня работает 7...
Я хочу сделать образец кролика.Поэтому я попытался создать проект, включающий «AMQP in I / O» в STS
Я установил параметр autoDelete как true для очереди, но иногда, даже если потребитель равен 0,...
типы данных заголовков Я пытаюсь отправить сообщение напрямую в Exchange с помощью конечной точки...
Я хочу настроить кластер rabbitmq за балансировщиком нагрузки и подключиться к нему с помощью...
Предполагается, что обмен разветвления направляет полученные сообщения во все очереди, ограниченные...
Я хочу написать тестовые случаи для SimpMessagingTemplate, используя rabbitmq в springboot. Я уже...
Я новичок в rabbitmq и в настоящее время пытаюсь реализовать неблокирующего производителя с...
Я настроил настройку параллелизма по умолчанию, и у меня есть другая группа, которой нужен другой...
Я использую Spring Boot для этого проекта микросервисов, я знаю, как отправлять / получать...
Я наткнулся на функцию очереди обратного вызова в RMQ.И это довольно необычно.Вся идея в том, что я...
Я использую самозаверяющие сертификаты на своем сервере Rabbitmq, и брокер успешно запускается с...