Cancel pending request in flush

jderusse · jderusse · commit 141971b13d8e · 2019-08-09T09:56:32.000+02:00
diff --git a/src/Symfony/Component/Messenger/Transport/SqsExt/Connection.php b/src/Symfony/Component/Messenger/Transport/SqsExt/Connection.php
@@ -240,6 +240,10 @@ public function requeue(string $id, int $delay = 0): void
 
     public function requeuePrefetchedMessages(): void
     {
+        if ($this->currentResponse !== null) {
+            $this->currentResponse->cancel();
+        }
+
         foreach ($this->getPendingMessages() as $message) {
             $this->requeue($message['id']);
         }

Original file line number	Diff line number	Diff line change
`@@ -240,6 +240,10 @@ public function requeue(string $id, int $delay = 0): void`
`240`	`240`
`241`	`241`	`public function requeuePrefetchedMessages(): void`
`242`	`242`	`{`
	`243`	`+ if ($this->currentResponse !== null) {`
	`244`	`+ $this->currentResponse->cancel();`
	`245`	`+ }`
	`246`	`+`
`243`	`247`	`foreach ($this->getPendingMessages() as $message) {`
`244`	`248`	`$this->requeue($message['id']);`
`245`	`249`	`}`