[rabbitmq-discuss] Turning off prefetch in the asynchronous_consumer_example
mcintoshj at gmail.com
Fri Mar 8 04:12:18 GMT 2013
Are you sure you're not seeing it as an auto-ack issue? Not sure enough of what's going on, but if you're only seeing one un-ack'd message when the second comes in, it's just checked out the message and waiting for an ack. If you want to auto-acknowledge the messages, I believe that's an option to the consumer.
On Mar 7, 2013, at 12:16 PM, Scott Chapman wrote:
> Code from here:
> I've tried putting the qos call here:
> def on_channel_open(self, channel):
> """This method is invoked by pika when the channel has been opened.
> The channel object is passed in so we can make use of it.
> Since the channel is now open, we'll declare the exchange to use.
> :param pika.channel.Channel channel: The channel object
> LOGGER.debug('Channel opened')
> self._channel = channel
> It did not turn off prefetching. Messages still show up in RabbitMQ as Unacknowledged rather than Ready when I send one and send a 2nd before the 1st is done processing.
> What am I missing?
> I want to turn off prefetching.
> I can't figure out how to turn it off on the Connection. That would be preferable, or turn it off globally.
> Any clues GREATLY appreciated.
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the rabbitmq-discuss