From 4330c6e939c5b54d10b35be55bbe1bc8779cea00 Mon Sep 17 00:00:00 2001 From: sebprt Date: Fri, 17 Nov 2023 16:40:00 +0100 Subject: [PATCH] Used the run method to call the flush method provided in th bunny client --- src/Rejection.php | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/Rejection.php b/src/Rejection.php index f7f6859..07f56c0 100644 --- 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