Проблема с очередью RabbitMQ. Слушатель сообщений не использует первые два сообщения - PullRequest
Новая
       61

Проблема с очередью RabbitMQ. Слушатель сообщений не использует первые два сообщения

1 голос
/ 01 апреля 2020

Здравствуйте! У меня очередь RabbitMQ, созданная из приложения A. Я хочу получать сообщения из этой очереди, поэтому я создал прослушиватель сообщений в приложении весенней загрузки, используя эту зависимость: 

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

После этого я делаю этот сценарий : 1. Запустите приложение весенней загрузки. 2. Отправьте сообщение в очередь

. Проблема в том, что первые два сообщения не прослушиваются слушателем. Вот почему я создаю прослушиватель сообщений только в Java, но у меня та же проблема. В управлении RabbitMQ я вижу, что сообщение опубликовано и не используется ... Я перепробовал много разных конфигураций, но ни одна из них не удалась. Когда я создаю очередь вручную, все работает правильно. Поэтому я сомневаюсь, что приложение A не создает очередь правильно или с некоторыми аргументами (даже если в менеджере RabbitMQ политика Args не остается рядом с именем очереди)

Свойства сообщения успешно использованы message: Это свойства сообщения успешно использованного сообщения: 

MessageProperties [headers={}, correlationId= TODO_requestID, replyTo=ME, contentType=application/json, contentLength=0, redelivered=false, receivedExchange=me-exchange, receivedRoutingKey=from-me, deliveryTag=1, consumerTag=amq.ctag-vPDSoiCHmWcb0v0NrINbIg, consumerQueue=from-me])

1 Ответ

1 голос
/ 05 апреля 2020

Go в RabbitMQ Mannagment откройте очередь и проверьте, есть ли другие потребители. Возможно, некоторые другие потребители собирают первые два сообщения.

Я столкнулся с подобной проблемой ..

...