Merge pull request php-amqplib#14 from panosru/patch-1

Pass the whole message object to consumer - BC break change
tobiasnaumann · Jan 3, 2012 · a2ed9a7 · a2ed9a7
2 parents 9c9797a + d7cf157
commit a2ed9a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/RabbitMq/Consumer.php b/RabbitMq/Consumer.php
@@ -28,7 +28,7 @@ public function processMessage(AMQPMessage $msg)
         try
         {
             //TODO pass the whole message and document the usage.
-            call_user_func($this->callback, $msg->body);
+            call_user_func($this->callback, $msg);
             $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
             $this->consumed++;
             $this->maybeStopConsumer($msg);