Cleanup

Messenger/KafkaTransport.php

@@ -35,6 +35,9 @@ class KafkaTransport implements TransportInterface
     /** @var string */
     private $topicName;
 
+    /** @var int */
+    private $flushTimeoutMs;
+
     /** @var int */
     private $receiveTimeoutMs;
 
@@ -44,9 +47,6 @@ class KafkaTransport implements TransportInterface
     /** @var bool */
     private $subscribed;
 
-    /** @var int */
-    private $flushTimeoutMs;
-
     public function __construct(
         LoggerInterface $logger,
         SerializerInterface $serializer,
@@ -138,14 +138,6 @@ public function reject(Envelope $envelope): void
         // Do nothing. auto commit should be set to false!
     }
 
-    /**
-     * Sends the given envelope.
-     *
-     * The sender can read different stamps for transport configuration,
-     * like delivery delay.
-     *
-     * If applicable, the returned Envelope should contain a TransportMessageIdStamp.
-     */
     public function send(Envelope $envelope): Envelope
     {
         $producer = $this->getProducer();