Я могу создать разветвленную биржу с помощью публикации / подписки RabbitMQ Java учебник, и любой подключенный потребитель получит копию сообщения. Вместо того, чтобы объявлять обмен и привязку динамически / программно, я хотел бы создать обмен и...

Я хочу определить очередь таким образом, чтобы все сообщения, поступающие в нее, направлялись другому рабочему и в то же время совместно использовались одним из рабочих, я думаю, диаграмма может объяснить лучше W(i) - Worker, который получает...

Я новичок в RabbitMQ, я только что просмотрел документы Rabbitmq (маршрутизация). Я совсем запутался между Exchange и ключами маршрутизации. Мое требование: я хочу динамически создавать несколько очередей. Пожалуйста, обратитесь к приведенной ниже...

пожалуйста, сначала посмотрите на мой код. Это мой тестовый класс , который создает 2000 потоков , и эти потоки отправляют сообщения. public class MessageSenderMultipleThreadMock { @Autowired MessageList message; @Autowired...

Имеются следующие два класса конфигурации : @Configuration @EnableRabbit @Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class }) public class RabbitConfigA { @Autowired @Qualifier("rabbitConnectionFactory_A") private...

Я использую spring-boot-starter-amqp 1.4.2. Производитель и потребитель работают нормально, но иногда входящие сообщения JSON имеют неправильный синтаксис. Это приводит к следующему (правильному) исключению:...

Я пытаюсь добавить некоторую функциональность для rabbitmq с сообщениями о задержке. На самом деле мне нужно получить это сообщение через 2 недели. Насколько я знаю, нам не нужен никакой плагин. Кроме того, когда это сообщение вызывается, как мне...

Я наткнулся на интересную тему, когда читал книгу «RabbitMQ в действии» Мэннинга. По-видимому, можно настроить потребителей так, чтобы они могли получать все журналы RabbitMQ в режиме реального времени в потребителе. Я читал, что RabbitMQ...

Я сделал ошибку: теперь обе очереди явно привязаны к какому-то обмену, который я могу редактировать для каждой очереди. Одна из этих очередей должна быть привязана к обмену по умолчанию. Теперь, когда я пытаюсь изменить обмен этой очереди на пустую...

Можно ли запланировать сообщение с помощью RabbitMQ, а также удалить сообщение (которое планируется обработать) при соблюдении определенных условий? У нас есть требование, когда нам нужно вызвать внешнюю службу для получения некоторых данных. Вызов...

У меня есть одна очередь в RabbitMQ, где одновременно может стоять 5-6 задач. В настоящее время в очереди есть один работник, который принимает по одной задаче за раз, и до тех пор, пока указанная задача не будет завершена и подтверждена, другие...

Мое веб-приложение .net core3.1 имеет, скажем, 4 микросервиса (MasterMS, PartyMS, ProductMS, PurchaseMS) и использует Rabbitmq в качестве брокера сообщений. В одном конкретном сценарии MasterMS публикует событие (вставка / обновление в таблице...