P
P
pauchog2018-04-10 10:06:09
RabbitMQ
pauchog, 2018-04-10 10:06:09

How to filter the queue (Unacked -> Ready)?

I receive all messages from the queue, then, based on some values ​​from the message headers, I form a filter in order to discard / skip some of the messages, and process the remaining ones. The problem is that after receiving all the messages, to form a filter, these messages become unacked , even if I do BasicNack multiple=true, requeue=true. After disabling the BasicCancel consumer, nothing happens either, they remain unacked.
In order to select messages again for processing using the generated filter, you have to close the session (Close) with and re-open it (CreateModel). I suspect there must be some other solution. Tell me where to dig?

Answer the question

In order to leave comments, you need to log in

2 answer(s)
P
pauchog, 2018-04-11
@pauchog

The answer to the question is here

S
Sergey, 2018-04-10
@yarkin

A strange situation, if they don’t help you here, try asking a question in the official Google group. And delivery-tag at nack'e goes from the last received message? And don't forget that the server will no longer send these messages to the same channel:

The server MUST NOT deliver the message to the same client within the context of the current channel.

Didn't find what you were looking for?

Ask your question

Ask a Question

731 491 924 answers to any question