Used the run method to call the flush method provided in th bunny client

php-etl · Nov 21, 2023 · 4330c6e · 4330c6e
1 parent 3e16e14
commit 4330c6e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/Rejection.php b/src/Rejection.php
@@ -84,6 +84,8 @@ public function reject(object|array $rejection, ?\Throwable $exception = null):
             $this->exchange,
             $this->topic,
         );
+
+        $this->channel->getClient()->run(0);
     }
 
     public function initialize(): void