<html><head></head><body style="word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-line-break: after-white-space; ">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. <div><br></div><div>Jason</div><div><br><div><div>On Mar 7, 2013, at 12:16 PM, Scott Chapman wrote:</div><br class="Apple-interchange-newline"><blockquote type="cite">
<meta http-equiv="Content-Type" content="text/html; charset=us-ascii">
<div 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>
</div>
_______________________________________________<br>rabbitmq-discuss mailing list<br><a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss<br></blockquote></div><br></div></body></html>