feat(Messenger): message reject

Author: Guikingone

components/messenger.rst

@@ -268,6 +268,7 @@ do is to write your own CSV receiver::
 
     use App\Message\NewOrder;
     use Symfony\Component\Messenger\Envelope;
+    use Symfony\Component\Messenger\Exception\MessageDecodingFailedException;
     use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
     use Symfony\Component\Serializer\SerializerInterface;
 
@@ -291,7 +292,15 @@ do is to write your own CSV receiver::
                 return [];
             }
             
-            // Reject the message if needed
+            try {
+                $envelope = $this->serializer->decode([
+                    'body' => $yourEnvelope['body'],
+                    'headers' => $yourEnvelope['headers'],
+                ]);
+            } catch (MessageDecodingFailedException $exception) {
+                $this->connection->reject($yourEnvelope['id']);
+                throw $exception;
+            }
             
             return [$yourEnvelope->with(new CustomStamp($yourEnvelope['id']);
         }
@@ -303,7 +312,8 @@ do is to write your own CSV receiver::
 
         public function reject(Envelope $envelope): void
         {
-            // Reject the message if needed
+            // In the case of a custom connection
+            $this->connection->reject($this->findCustomStamp($envelope)->getId());
         }
     }