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
Uh oh!
There was an error while loading. Please reload this page.
-
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