Optimized exchange declaration for consumer messages (#6717)

hyperf · Apr 26, 2024 · f66439c · f66439c
1 parent 0d6e7ac
commit f66439c
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -57,14 +57,12 @@ public function consume(ConsumerMessageInterface $consumerMessage): void
             $channel = $connection->getConfirmChannel();
             $exchange = $consumerMessage->getExchange();
 
-            if (! DeclaredExchanges::has($exchange)) {
-                try {
-                    DeclaredExchanges::add($exchange);
-                    $this->declare($consumerMessage, $channel);
-                } catch (Throwable $exception) {
-                    DeclaredExchanges::remove($exchange);
-                    throw $exception;
-                }
+            try {
+                DeclaredExchanges::add($exchange);
+                $this->declare($consumerMessage, $channel);
+            } catch (Throwable $exception) {
+                DeclaredExchanges::remove($exchange);
+                throw $exception;
             }
 
             $concurrent = $this->getConcurrent($consumerMessage->getPoolName());