Unable to cancel consumers

[pastTenseVerb]

Unable to cancel consumers

[cressie176]

When you set prefetch to 50, you are telling RabbitMQ deliver messages concurrently until there are 50 unacknowledged messages for this consumer. By the time you have called channel.cancel(), Rabbit has already delivered 50 messages. Cancelling will only stop subsequent messages from being delivered.

To achieve what I think you want, you need to set the prefetch to 1. Then you probably don't need to cancel the consumer, since you will only be handling one message at a time. The alternative is to explicitly get a message from the channel. The documentation can be found here. The drawback is when the queue is empty, you will have to decide how frequently to poll.

[cressie176]

Hi @pastTenseVerb,

It looks like you are not setting a channel prefetch. This means that RabbitMQ will deliver all messages concurrently, hence the messages will have all been delivered before you cancel the consumer. Instead you need to either switch to using channel.get or set a channel prefetch.

[pastTenseVerb]

When I add a prefetch of 50, it does stop all 500 from getting consumed but I'm still consuming 50 after I call channel.cancel() so not much has changed. I can switch to using channel.get but are there any drawbacks to doing so?

Also do you think it's possible I'm getting false positives by running a rabbitMQ container locally? I'm sure channel.cancel works as intended since there aren't many issues brought up about it.

[cressie176]

OK to close @pastTenseVerb?