Merge pull request #35 from Vinelab/fix/handler-memory-management

Consumer: move handler initialisation to inside the message receipt callback
Vinelab · Nov 12, 2018 · af8f56e · af8f56e
2 parents d148f55 + 4599ac8
commit af8f56e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -139,10 +139,10 @@ public function listenToQueue($handlerClass, BowlerExceptionHandler $exceptionHa
             $channel->queue_bind($this->queueName, $this->exchangeName);
         }
 
-        // Instantiate Handler
-        $queueHandler = app($handlerClass);
+        $callback = function ($message) use ($handlerClass, $exceptionHandler) {
+            // Instantiate Handler
+            $queueHandler = app($handlerClass);
 
-        $callback = function ($message) use ($queueHandler, $exceptionHandler) {
             $broker = new MessageBroker($message);
 
             try {