<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=us-ascii">
</head>
<body style="word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-line-break: after-white-space; color: rgb(0, 0, 0); font-size: 14px; font-family: Calibri, sans-serif; ">
<div>Code from here:</div>
<div><a href="https://github.com/pika/pika/blob/master/docs/examples/asynchronous_consumer_example.rst">https://github.com/pika/pika/blob/master/docs/examples/asynchronous_consumer_example.rst</a></div>
<div><br>
</div>
<div>I've tried putting the qos call here:</div>
<div><br>
</div>
<div>
<div> def on_channel_open(self, channel):</div>
<div> """This method is invoked by pika when the channel has been opened.</div>
<div> The channel object is passed in so we can make use of it.</div>
<div><br>
</div>
<div> Since the channel is now open, we'll declare the exchange to use.</div>
<div><br>
</div>
<div> :param pika.channel.Channel channel: The channel object</div>
<div><br>
</div>
<div> """</div>
<div> LOGGER.debug('Channel opened')</div>
<div> channel.basic_qos(prefetch_count=1)</div>
<div> self._channel = channel</div>
<div> self.add_on_channel_close_callback()</div>
<div> self.setup_exchange(self.EXCHANGE)</div>
</div>
<div><br>
</div>
<div>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.</div>
<div><br>
</div>
<div>What am I missing?</div>
<div><br>
</div>
<div>I want to turn off prefetching.</div>
<div>I can't figure out how to turn it off on the Connection. That would be preferable, or turn it off globally.</div>
<div><br>
</div>
<div>Any clues GREATLY appreciated.</div>
<div><br>
</div>
<div>Thanks,</div>
<div>Scott</div>
</body>
</html>