Replies: 1 comment
-
More than likely, the |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I have two queues:
queue1
andqueue2
.queue2
has two arguments:x-max-length: 10
andx-overflow: reject-publish
.I want to move messages from
queue1
toqueue2
and it is important for me that no messages get lost.Here is my code
The
OnAcknowledged
method is called when a message has been delivered toqueue2
.The
OnNotAcknowledged
method is called when a message has not been delivered toqueue2
.Thus, if at first there were
100
messages inqueue1
and0
inqueue2
, then after starting something like this happens:10
messages are added toqueue2
(since there is such a limitation on it), andqueue1
can be95
, that is, theOnAcknowledged
method was called in total5 times
, although all10
messages were successfully delivered.Is this intended behavior or am I doing something wrong?
Environment:
.Net Core version: 3.1
RabbitMQ Server version: 3.8.11
RabbitMQ.Client version: 6.2.1
Sorry, I don't know English well, so I use a translator
Beta Was this translation helpful? Give feedback.
All reactions