fixed #18

workbunny · Nov 19, 2023 · a88ba72 · a88ba72
1 parent e6cea7c
commit a88ba72
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/src/Connection.php b/src/Connection.php
@@ -191,22 +191,24 @@ public function syncPublish(BuilderConfig $config, bool $close = false): bool
                     $config->getQueue(), $config->getExchange(), $config->getRoutingKey(), $config->isNowait(),
                     $config->getArguments()
                 );
-            }catch (Throwable $throwable){
+            } catch (Throwable $throwable){
                 if($this->getErrorCallback()){\call_user_func($this->getErrorCallback(), $throwable, $this);}
                 $this->close($this->getSyncClient(), $throwable);
                 return false;
             }
         }
-
-        return $channel->publish(
-            $config->getBody(), $config->getHeaders(), $config->getExchange(), $config->getRoutingKey(),
-            $config->isMandatory(), $config->isImmediate()
-        )->then(function () use ($close) {
-            if($close) {$this->close($this->getAsyncClient());}
-        }, function (Throwable $throwable) {
+        try {
+            $res = (bool)$channel->publish(
+                $config->getBody(), $config->getHeaders(), $config->getExchange(), $config->getRoutingKey(),
+                $config->isMandatory(), $config->isImmediate()
+            );
+            if($close) {$this->close($this->getSyncClient());}
+            return $res;
+        } catch (Throwable $throwable){
             if($this->getErrorCallback()){\call_user_func($this->getErrorCallback(), $throwable, $this);}
             $this->close($this->getSyncClient(), $throwable);
-        })->done();
+            return false;
+        }
     }
 
     /**