closure fix for multiple consumers

Author: itcreator

RabbitMq/MultipleConsumer.php

@@ -30,7 +30,7 @@ protected function setupConsumer()
             $currentObject = $this;
 
             $this->getChannel()->basic_consume($name, $this->getQueueConsumerTag($name), false, false, false, false, function (AMQPMessage $msg) use($currentObject, $name) {
-                $this->processQueueMessage($name, $msg);
+                $currentObject->processQueueMessage($name, $msg);
             });
         }
     }