Now only disconnects the PUSH connection on a timeout waiting for publish acks (#15)

rgooding · bajb · commit 63171f52064e · 2018-07-04T11:00:51.000+01:00
diff --git a/src/Provider/Amqp/AmqpQueueProvider.php b/src/Provider/Amqp/AmqpQueueProvider.php
@@ -180,7 +180,7 @@ public function pushBatch(array $batch, $persistent = null)
         }
         catch(\Exception $e)
         {
-          $this->disconnectAll();
+          $this->disconnect(self::CONN_PUSH);
           if($autoDeclare
             && ($declareAttempts < $declareRetryLimit)
             && ($e->getCode() == 404)

Original file line number	Diff line number	Diff line change
`@@ -180,7 +180,7 @@ public function pushBatch(array $batch, $persistent = null)`
`180`	`180`	`}`
`181`	`181`	`catch(\Exception $e)`
`182`	`182`	`{`
`183`		`- $this->disconnectAll();`
	`183`	`+ $this->disconnect(self::CONN_PUSH);`
`184`	`184`	`if($autoDeclare`
`185`	`185`	`&& ($declareAttempts < $declareRetryLimit)`
`186`	`186`	`&& ($e->getCode() == 404)`