<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=Windows-1252">
</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>It's not auto-ack. That's disabled. I don't want them auto-ack'd.</div>
<div><br>
</div>
<div>I don’t want it to "check out the message". That's prefetching. I want it to leave the message alone until it's ready to be processed.</div>
<div><br>
</div>
<div>Scott</div>
<div><br>
</div>
<span id="OLK_SRC_BODY_SECTION">
<div style="font-family:Calibri; font-size:11pt; text-align:left; color:black; BORDER-BOTTOM: medium none; BORDER-LEFT: medium none; PADDING-BOTTOM: 0in; PADDING-LEFT: 0in; PADDING-RIGHT: 0in; BORDER-TOP: #b5c4df 1pt solid; BORDER-RIGHT: medium none; PADDING-TOP: 3pt">
<span style="font-weight:bold">From: </span>McIntosh Jason <<a href="mailto:mcintoshj@gmail.com">mcintoshj@gmail.com</a>><br>
<span style="font-weight:bold">Reply-To: </span>Discussions about RabbitMQ <<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a>><br>
<span style="font-weight:bold">Date: </span>Thursday, March 7, 2013 8:12 PM<br>
<span style="font-weight:bold">To: </span>Discussions about RabbitMQ <<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a>><br>
<span style="font-weight:bold">Subject: </span>Re: [rabbitmq-discuss] Turning off prefetch in the asynchronous_consumer_example<br>
</div>
<div><br>
</div>
<div>
<div 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">
<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>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
</blockquote>
</div>
<br>
</div>
</div>
</div>
</span>
</body>
</html>