From 0711760566bb9c538e21945874acc1526a0907eb Mon Sep 17 00:00:00 2001
From: "Roland Franssen :)" <franssen.roland@gmail.com>
Date: Mon, 20 Nov 2023 13:16:45 +0100
Subject: [PATCH] Update Consumer.php

---
 src/Consumer/Consumer.php | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php
index fadaea6..5f0cb9f 100644
--- 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);
             }
         });