From 1fea50b0c7e96ff13d0e117377c9d3e3ae6d1ab7 Mon Sep 17 00:00:00 2001
From: Konstantin Scheumann <konstantin@konstantin.codes>
Date: Mon, 4 May 2020 10:24:24 +0200
Subject: [PATCH] Cleanup

---
 Messenger/KafkaTransport.php | 14 +++-----------
 1 file changed, 3 insertions(+), 11 deletions(-)

diff --git a/Messenger/KafkaTransport.php b/Messenger/KafkaTransport.php
index 296b81d..f6a4393 100644
--- a/Messenger/KafkaTransport.php
+++ b/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();