[Messenger] Use CPP

Author: derrabus

Tests/Fixtures/DummyMessage.php

@@ -4,11 +4,9 @@
 
 class DummyMessage
 {
-    private string $message;
-
-    public function __construct(string $message)
-    {
-        $this->message = $message;
+    public function __construct(
+        private string $message,
+    ) {
     }
 
     public function getMessage(): string

Transport/BeanstalkdReceivedStamp.php

@@ -18,13 +18,10 @@
  */
 class BeanstalkdReceivedStamp implements NonSendableStampInterface
 {
-    private string $id;
-    private string $tube;
-
-    public function __construct(string $id, string $tube)
-    {
-        $this->id = $id;
-        $this->tube = $tube;
+    public function __construct(
+        private string $id,
+        private string $tube,
+    ) {
     }
 
     public function getId(): string

Transport/BeanstalkdReceiver.php

@@ -24,12 +24,12 @@
  */
 class BeanstalkdReceiver implements ReceiverInterface, MessageCountAwareInterface
 {
-    private Connection $connection;
     private SerializerInterface $serializer;
 
-    public function __construct(Connection $connection, ?SerializerInterface $serializer = null)
-    {
-        $this->connection = $connection;
+    public function __construct(
+        private Connection $connection,
+        ?SerializerInterface $serializer = null,
+    ) {
         $this->serializer = $serializer ?? new PhpSerializer();
     }
 

Transport/BeanstalkdSender.php

@@ -22,12 +22,12 @@
  */
 class BeanstalkdSender implements SenderInterface
 {
-    private Connection $connection;
     private SerializerInterface $serializer;
 
-    public function __construct(Connection $connection, ?SerializerInterface $serializer = null)
-    {
-        $this->connection = $connection;
+    public function __construct(
+        private Connection $connection,
+        ?SerializerInterface $serializer = null,
+    ) {
         $this->serializer = $serializer ?? new PhpSerializer();
     }
 

Transport/BeanstalkdTransport.php

@@ -22,14 +22,14 @@
  */
 class BeanstalkdTransport implements TransportInterface, MessageCountAwareInterface
 {
-    private Connection $connection;
     private SerializerInterface $serializer;
     private BeanstalkdReceiver $receiver;
     private BeanstalkdSender $sender;
 
-    public function __construct(Connection $connection, ?SerializerInterface $serializer = null)
-    {
-        $this->connection = $connection;
+    public function __construct(
+        private Connection $connection,
+        ?SerializerInterface $serializer = null,
+    ) {
         $this->serializer = $serializer ?? new PhpSerializer();
     }
 

Transport/Connection.php

@@ -34,23 +34,24 @@ class Connection
         'ttr' => 90,
     ];
 
+    private string $tube;
+    private int $timeout;
+    private int $ttr;
+
     /**
-     * Available options:.
+     * Constructor.
+     *
+     * Available options:
      *
      * * tube_name: name of the tube
      * * timeout: message reservation timeout (in seconds)
      * * ttr: the message time to run before it is put back in the ready queue (in seconds)
      */
-    private array $configuration;
-    private PheanstalkInterface $client;
-    private string $tube;
-    private int $timeout;
-    private int $ttr;
-
-    public function __construct(array $configuration, PheanstalkInterface $client)
-    {
+    public function __construct(
+        private array $configuration,
+        private PheanstalkInterface $client,
+    ) {
         $this->configuration = array_replace_recursive(self::DEFAULT_OPTIONS, $configuration);
-        $this->client = $client;
         $this->tube = $this->configuration['tube_name'];
         $this->timeout = $this->configuration['timeout'];
         $this->ttr = $this->configuration['ttr'];