Update Publisher.php

microThread · web-flow · commit c065826bb405 · 2020-10-08T08:56:39.000+03:00
diff --git a/src/Publisher.php b/src/Publisher.php
@@ -133,8 +133,6 @@ public function publish(Amqp\AmqpMessage $message, $retry = 0, $onRetry = null,
             } catch (\Exception $exception) {
                 $error = $exception;
 
-                $this->producer(true);
-
                 if (isset($onRetry) && \is_callable($onRetry)) {
                     \call_user_func_array($onRetry, [$this, $error]);
                 }

Original file line number	Diff line number	Diff line change
`@@ -133,8 +133,6 @@ public function publish(Amqp\AmqpMessage $message, $retry = 0, $onRetry = null,`
`133`	`133`	`} catch (\Exception $exception) {`
`134`	`134`	`$error = $exception;`
`135`	`135`
`136`		`- $this->producer(true);`
`137`		`-`
`138`	`136`	`if (isset($onRetry) && \is_callable($onRetry)) {`
`139`	`137`	`\call_user_func_array($onRetry, [$this, $error]);`
`140`	`138`	`}`