<div dir="ltr">Thanks again for the quick response.<div><br></div><div>I also read <a href="http://www.rabbitmq.com/extensions.html#publishing">http://www.rabbitmq.com/extensions.html#publishing</a> before posting this question.</div>
<div><br></div><div>But again my problem is with simulating server nacks so i can create a test case for my code.</div><div><br></div><div>Do you have any idea how I can do that?</div><div><br><div class="gmail_quote">On Mon, Nov 28, 2011 at 1:26 PM, Marek Majkowski <span dir="ltr"><<a href="mailto:majek04@gmail.com">majek04@gmail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;"><div class="im">On Mon, Nov 28, 2011 at 11:11, Roey Berman <<a href="mailto:roey.berman@gmail.com">roey.berman@gmail.com</a>> wrote:<br>
> Oh one fix:<br>
> self.chan.basic_publish(message, **kwargs) -> self.chan.basic_publish(body =<br>
> message, **kwargs)<br>
><br>
> On Mon, Nov 28, 2011 at 1:08 PM, Roey Berman <<a href="mailto:roey.berman@gmail.com">roey.berman@gmail.com</a>> wrote:<br>
>><br>
>> Thanks for the quick reply.<br>
>> At first I used the code from the example you referred me to but it<br>
>> doesn't handle the "multiple" flag and NAcks from the server.<br>
>> I know my code handles the "multiple" flag, but don't know about NAcks.<br>
>> I don't really know how to test for nacks since I've never gotten them<br>
>> from rabbitmq server.<br>
<br>
</div><a href="http://www.rabbitmq.com/extensions.html#publishing" target="_blank">http://www.rabbitmq.com/extensions.html#publishing</a><br>
<br>
"In exceptional cases when the broker is unable to handle messages<br>
successfully, instead of a basic.ack, the broker will send a<br>
basic.nack. In this context, fields of the basic.nack have the same<br>
meaning as the corresponding ones in basic.ack and the requeue field<br>
should be ignored. By nack'ing one or more messages, the broker<br>
indicates that it was unable to process the messages and refuses<br>
responsibility for them; at that point, the client may choose to<br>
re-publish the messages.<br>
<br>
After a channel is put into confirm mode, all subsequently published<br>
messages will be confirmed or nack'd once. No guarantees are made as<br>
to how soon a message is confirmed. No message will be both confirmed<br>
and nack'd."<br>
<br>
That's all I know.<br>
<div class="im"><br>
<br>
>> Once I know my code handles all responses correctly I will create a pull<br>
>> request for the pika example code.<br>
<br>
</div>Good!<br>
<span class="HOEnZb"><font color="#888888"><br>
Marek<br>
</font></span><div class="HOEnZb"><div class="h5"><br>
<br>
>> On Mon, Nov 28, 2011 at 1:01 PM, Marek Majkowski <<a href="mailto:majek04@gmail.com">majek04@gmail.com</a>><br>
>> wrote:<br>
>>><br>
>>> Hi,<br>
>>><br>
>>> I'm not sure if it works - but the pika example showing<br>
>>> publisher confirms usage looks rather similar:<br>
>>><br>
>>><br>
>>> <a href="https://github.com/pika/pika/blob/120fdea5913e7ed80536ff55634ab0f8f4554e79/examples/demo_send_confirmed.py" target="_blank">https://github.com/pika/pika/blob/120fdea5913e7ed80536ff55634ab0f8f4554e79/examples/demo_send_confirmed.py</a><br>
>>><br>
>>> Cheer,<br>
>>> Marek<br>
>>><br>
>>> On Sun, Nov 27, 2011 at 15:20, bergundy <<a href="mailto:roey.berman@gmail.com">roey.berman@gmail.com</a>> wrote:<br>
>>> > Hi everyone,<br>
>>> ><br>
>>> > I couldn't find code for implementing publisher confirmations.<br>
>>> ><br>
>>> > I wrote this piece of code using pika 0.9.5 (python client).<br>
>>> > Would like to get feedback on this, I hope I got it right ...<br>
>>> ><br>
>>> > ---<br>
>>> > class ConfirmingProducer(object):<br>
>>> > def __init__(self, channel):<br>
>>> > self.delivery_tag = 1<br>
>>> > self.acked = 0<br>
>>> > self._callbacks = {}<br>
>>> > self.chan = channel<br>
>>> > self.chan.confirm_delivery(self.on_delivered)<br>
>>> ><br>
>>> > def publish(self, message, callback, **kwargs):<br>
>>> > self._callbacks[self.delivery_tag] = callback<br>
>>> > self.delivery_tag += 1<br>
>>> > self.chan.basic_publish(message, **kwargs)<br>
>>> ><br>
>>> > def on_delivered(self, frame):<br>
>>> > success = isinstance(frame.method, pika.spec.Basic.Ack)<br>
>>> ><br>
>>> > if frame.method.multiple:<br>
>>> > for dtag in range(self.acked+1, frame.method.delivery_tag<br>
>>> > +1):<br>
>>> > self._callbacks.pop(dtag)(success)<br>
>>> > self.acked = frame.method.delivery_tag<br>
>>> > else:<br>
>>> > self._callbacks.pop(frame.method.delivery_tag)(success)<br>
>>> > self.acked += 1<br>
>>> > _______________________________________________<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" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
>>> ><br>
>><br>
><br>
><br>
</div></div></blockquote></div><br></div></div>