Repeated Acknowledgements with SetBody()

[rayanimesh]

I checked issues list and didn't found related issue in list.

I am opening Channel in confirm_select() mode and then publishing a single message multiple times with different message bodies using setBody(). But I am getting acknowledgements with last sent message body.

Sample Code:

$msg = new AMQPMessage($msg_body);
$i       = 1;
while($i<11)
{
       $msg_body = $i++;
       $msg->setBody($msg_body);
       $ch->basic_publish($msg, $exchange);
}
$ch->wait_for_pending_acks();

It will provide me 11 acknowledgements with message body 11.
We are storing message into published_messages array when we publish a message into exchange.

     $this->published_messages[$this->next_delivery_tag] = $msg; 

When we use setBody() function to change body of message it is changing message body of published_message array. (Due to by reference objects passing in PHP5 which keeps reference of message body).

Cloning $msg and then saving into published_message worked for me.

Can you look into this?

[videlalvaro]

The setBody() thingie is there mostly if you need to publish as fast as possible, but in your case I would just create a new instance AMQPMessage instance.

[rayanimesh]

Hi,
Thanks for quick reply.
I want to achieve high performance so I don't want to create a new AMQPMessage instance each time. I tried creating new message instance each time but it slowed performance by 100% (Reusing takes ~2ms while creating new instance takes ~4ms).

But reusing message body leads to repeated acknowledgements as I mentioned. And we can fix it, by storing cloned message into published_message array.

     $this->published_messages[$this->next_delivery_tag] =  clone($msg); 

Or am I missing something?

[lukebakken]

Closing due to inactivity, and due to workarounds in place.