bendavies
diff --git a/‎src/Symfony/Component/Messenger/EventListener/SendFailedMessageForRetryListener.php
Lines changed: 4 additions & 3 deletions b/‎src/Symfony/Component/Messenger/EventListener/SendFailedMessageForRetryListener.php
Lines changed: 4 additions & 3 deletions
diff --git a/‎src/Symfony/Component/Messenger/Tests/EventListener/SendFailedMes 8000 sageForRetryListenerTest.php
Lines changed: 22 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Tests/EventListener/SendFailedMes 8000 sageForRetryListenerTest.php
Lines changed: 22 additions & 1 deletion
@@ -123,7 +123,8 @@ public static function getSubscribedEvents()
 
     private function shouldRetry(\Throwable $e, Envelope $envelope, RetryStrategyInterface $retryStrategy): bool
     {
-        if ($e instanceof RecoverableExceptionInterface) {
+        $isRetryable = $retryStrategy->isRetryable($envelope, $e);
+        if ($isRetryable && $e instanceof RecoverableExceptionInterface) {
             return true;
         }
 
@@ -132,7 +133,7 @@ private function shouldRetry(\Throwable $e, Envelope $envelope, RetryStrategyInt
         if ($e instanceof HandlerFailedException) {
             $shouldNotRetry = true;
             foreach ($e->getNestedExceptions() as $nestedException) {
-                if ($nestedException instanceof RecoverableExceptionInterface) {
+                if ($isRetryable && $nestedException instanceof RecoverableExceptionInterface) {
                     return true;
                 }
 
@@ -150,7 +151,7 @@ private function shouldRetry(\Throwable $e, Envelope $envelope, RetryStrategyInt
             return false;
         }
 
-        return $retryStrategy->isRetryable($envelope, $e);
+        return $isRetryable;
     }
 
     private function getRetryStrategyForTransport(string $alias): ?RetryStrategyInterface
 
@@ -63,7 +63,7 @@ public function testRecoverableStrategyCausesRetry()
         $senderLocator->expects($this->once())->method('has')->willReturn(true);
         $senderLocator->expects($this->once())->method('get')->willReturn($sender);
         $retryStategy = $this->createMock(RetryStrategyInterface::class);
-        $retryStategy->expects($this->never())->method('isRetryable');
+        $retryStategy->expects($this->once())->method('isRetryable')->willReturn(true);
         $retryStategy->expects($this->once())->method('getWaitingTime')->willReturn(1000);
         $retryStrategyLocator = $this->createMock(ContainerInterface::class);
         $retryStrategyLocator->expects($this->once())->method('has')->willReturn(true);
@@ -78,6 +78,27 @@ public function testRecoverableStrategyCausesRetry()
         $listener->onMessageFailed($event);
     }
 
+    public function testRetryIsOnlyAllowedWhenPermittedByRetryStrategy()
+    {
+        $senderLocator = $this->createMock(ContainerInterface::class);
+        $senderLocator->expects($this->never())->method('has');
         $senderLocator->expects($this->never())->method('get');
+        $retryStrategy = $this->createMock(RetryStrategyInterface::class);
+        $retryStrategy->expects($this->once())->method('isRetryable')->willReturn(false);
+        $retryStrategy->expects($this->never())->method('getWaitingTime');
+        $retryStrategyLocator = $this->createMock(ContainerInterface::class);
+        $retryStrategyLocator->expects($this->once())->method('has')->willReturn(true);
+        $retryStrategyLocator->expects($this->once())->method('get')->willReturn($retryStrategy);
+
+        $listener = new SendFailedMessageForRetryListener($senderLocator, $retryStrategyLocator);
+
+        $exception = new RecoverableMessageHandlingException('retry');
+        $envelope = new Envelope(new \stdClass());
+        $event = new WorkerMessageFailedEvent($envelope, 'my_receiver', $exception);
+
+        $listener->onMessageFailed($event);
+    }
+
     public function testEnvelopeIsSentToTransportOnRetry()
     {
         $exception = new \Exception('no!');
Original file line number	Diff line number	Diff line change
`@@ -123,7 +123,8 @@ public static function getSubscribedEvents()`
`123`	`123`
`124`	`124`	`private function shouldRetry(\Throwable $e, Envelope $envelope, RetryStrategyInterface $retryStrategy): bool`
`125`	`125`	`{`
`126`		`- if ($e instanceof RecoverableExceptionInterface) {`
	`126`	`+ $isRetryable = $retryStrategy->isRetryable($envelope, $e);`
	`127`	`+ if ($isRetryable && $e instanceof RecoverableExceptionInterface) {`
`127`	`128`	`return true;`
`128`	`129`	`}`
`129`	`130`
`@@ -132,7 +133,7 @@ private function shouldRetry(\Throwable $e, Envelope $envelope, RetryStrategyInt`
`132`	`133`	`if ($e instanceof HandlerFailedException) {`
`133`	`134`	`$shouldNotRetry = true;`
`134`	`135`	`foreach ($e->getNestedExceptions() as $nestedException) {`
`135`		`- if ($nestedException instanceof RecoverableExceptionInterface) {`
	`136`	`+ if ($isRetryable && $nestedException instanceof RecoverableExceptionInterface) {`
`136`	`137`	`return true;`
`137`	`138`	`}`
`138`	`139`
`@@ -150,7 +151,7 @@ private function shouldRetry(\Throwable $e, Envelope $envelope, RetryStrategyInt`
`150`	`151`	`return false;`
`151`	`152`	`}`
`152`	`153`
`153`		`- return $retryStrategy->isRetryable($envelope, $e);`
	`154`	`+ return $isRetryable;`
`154`	`155`	`}`
`155`	`156`
`156`	`157`	`private function getRetryStrategyForTransport(string $alias): ?RetryStrategyInterface`