Update Consumer.php

basis-company · Nov 20, 2023 · 0711760 · 0711760
1 parent 7dfde72
commit 0711760
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php
@@ -114,11 +114,11 @@ public function handle(Closure $handler, Closure $emptyHandler = null, bool $ack
 
         $this->create();
 
-        $this->client->subscribe($handlerSubject, function ($message) use ($handler, $runtime) {
+        $this->client->subscribe($handlerSubject, function ($message, $replyTo) use ($handler, $runtime) {
             if (!$message->isEmpty()) {
                 $runtime->empty = false;
                 $runtime->processed++;
-                $handler($message);
+                $handler($message, $replyTo);
             }
         });