[Messenger] Fix opcache preload with alias classes

Author: jderusse

Transport/AmqpFactory.php

@@ -33,4 +33,7 @@ public function createExchange(\AMQPChannel $channel): \AMQPExchange
         return new \AMQPExchange($channel);
     }
 }
-class_alias(AmqpFactory::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpFactory::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpFactory::class, false)) {
+    class_alias(AmqpFactory::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpFactory::class);
+}

Transport/AmqpReceivedStamp.php

@@ -37,4 +37,7 @@ public function getQueueName(): string
         return $this->queueName;
     }
 }
-class_alias(AmqpReceivedStamp::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp::class, false)) {
+    class_alias(AmqpReceivedStamp::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp::class);
+}

Transport/AmqpReceiver.php

@@ -136,4 +136,7 @@ private function findAmqpStamp(Envelope $envelope): AmqpReceivedStamp
         return $amqpReceivedStamp;
     }
 }
-class_alias(AmqpReceiver::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver::class, false)) {
+    class_alias(AmqpReceiver::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver::class);
+}

Transport/AmqpSender.php

@@ -75,4 +75,7 @@ public function send(Envelope $envelope): Envelope
         return $envelope;
     }
 }
-class_alias(AmqpSender::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender::class, false)) {
+    class_alias(AmqpSender::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpSender::class);
+}

Transport/AmqpStamp.php

@@ -74,4 +74,7 @@ public static function createWithAttributes(array $attributes, self $previousSta
         );
     }
 }
-class_alias(AmqpStamp::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp::class, false)) {
+    class_alias(AmqpStamp::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpStamp::class);
+}

Transport/AmqpTransport.php

@@ -92,4 +92,7 @@ private function getSender(): AmqpSender
         return $this->sender = new AmqpSender($this->connection, $this->serializer);
     }
 }
-class_alias(AmqpTransport::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransport::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransport::class, false)) {
+    class_alias(AmqpTransport::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransport::class);
+}

Transport/AmqpTransportFactory.php

@@ -32,4 +32,7 @@ public function supports(string $dsn, array $options): bool
         return 0 === strpos($dsn, 'amqp://') || 0 === strpos($dsn, 'amqps://');
     }
 }
-class_alias(AmqpTransportFactory::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory::class, false)) {
+    class_alias(AmqpTransportFactory::class, \Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransportFactory::class);
+}

Transport/Connection.php

@@ -588,4 +588,7 @@ private function getRoutingKeyForMessage(?AmqpStamp $amqpStamp): ?string
         return (null !== $amqpStamp ? $amqpStamp->getRoutingKey() : null) ?? $this->getDefaultPublishRoutingKey();
     }
 }
-class_alias(Connection::class, \Symfony\Component\Messenger\Transport\AmqpExt\Connection::class);
+
+if (!class_exists(\Symfony\Component\Messenger\Transport\AmqpExt\Connection::class, false)) {
+    class_alias(Connection::class, \Symfony\Component\Messenger\Transport\AmqpExt\Connection::class);
+}