move handler initialisation to inside the message receipt callback

Vinelab · Nov 7, 2018 · 4599ac8 · 4599ac8
1 parent d148f55
commit 4599ac8
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 {