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

php-etl · Nov 17, 2023 · e377458 · e377458
1 parent 3e16e14
commit e377458
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/Rejection.php b/src/Rejection.php
@@ -72,7 +72,8 @@ public static function withAuthentication(
 
     public function reject(object|array $rejection, ?\Throwable $exception = null): void
     {
-        $this->channel->publish(
+        $this->connection->publish(
+            $this->channel->getChannelId(),
             json_encode([
                 'item' => $rejection,
                 'exception' => $exception,
@@ -84,6 +85,8 @@ public function reject(object|array $rejection, ?\Throwable $exception = null):
             $this->exchange,
             $this->topic,
         );
+
+        $this->connection->run(0);
     }
 
     public function initialize(): void