get channel about rabbitmqbundle HOT 6 CLOSED

Hi the message has a reference to the channel.

For example:

$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);

Take a look at the php-amqplib code. Sadly there's no docs for this yet.

from rabbitmqbundle.

Ok, I see, I actually implemented my own message object in order to push into rabbitmq queue but I will hook channel into it :)

Thanks for the answer.

from rabbitmqbundle.

Hello Alvaro, I just found some time to work with it, so the issue remains and also if i try to use $msg->delivery_info I get Notice: Trying to get property of non-object if I var_dump($msg); exit(); inside the execute method and then run the consumer in order to test the output I'm getting this: string(73) "a:2:{s:7:"user_id";i:1235;s:10:"image_path";s:20:"/path/to/new/pic.png";}" so it seems that the $msg is coming in plain serialized string format inside the execute method.

from rabbitmqbundle.

You are right. I think I have to pass the whole object message to the consumer and not just the $msg->body. I will look to change that and add a BC warning in the README

from rabbitmqbundle.

Hello Alvaro, I added some pull requests where in consumer and RPC server I passed the $msg object directly instead of $msg->body as it was before (I didn't thought of checking that before :P Thanks for the tip!)

from rabbitmqbundle.

@panosru I think now this can be closed since I merged your PR. Thanks

from rabbitmqbundle.