Fix CS

Author: andrewmy

pkg/enqueue/Tests/Client/Driver/RdKafkaDriverTest.php

@@ -99,9 +99,6 @@ protected function createQueue(string $name): InteropQueue
         return new RdKafkaTopic($name);
     }
 
-    /**
-     * @return RdKafkaTopic
-     */
     protected function createTopic(string $name): RdKafkaTopic
     {
         return new RdKafkaTopic($name);

pkg/gearman/Tests/Spec/GearmanSendToAndReceiveFromQueueTest.php

@@ -24,8 +24,7 @@ protected function createContext()
     }
 
     /**
-     * @param Context $context
-     * @param string  $queueName
+     * @param string $queueName
      *
      * @return Queue
      */

pkg/rdkafka/Tests/JsonSerializerTest.php

@@ -39,7 +39,7 @@ public function testThrowIfFailedToEncodeMessageToJson()
 
         $resource = fopen(__FILE__, 'r');
 
-        //guard
+        // guard
         $this->assertIsResource($resource);
 
         $message = new RdKafkaMessage('theBody', ['aProp' => $resource]);

pkg/rdkafka/Tests/RdKafkaConsumerTest.php

@@ -195,7 +195,7 @@ public function testShouldReceiveFromQueueAndReturnMessageIfMessageInQueue()
     {
         $destination = new RdKafkaTopic('dest');
 
-        $expectedMessage = new  RdKafkaMessage('theBody', ['foo' => 'fooVal'], ['bar' => 'barVal']);
+        $expectedMessage = new RdKafkaMessage('theBody', ['foo' => 'fooVal'], ['bar' => 'barVal']);
 
         $kafkaMessage = new Message();
         $kafkaMessage->err = RD_KAFKA_RESP_ERR_NO_ERROR;
@@ -260,7 +260,7 @@ public function testShouldAllowGetPreviouslySetSerializer()
 
         $expectedSerializer = $this->createSerializerMock();
 
-        //guard
+        // guard
         $this->assertNotSame($consumer->getSerializer(), $expectedSerializer);
 
         $consumer->setSerializer($expectedSerializer);

pkg/rdkafka/Tests/RdKafkaProducerTest.php

@@ -169,7 +169,7 @@ public function testShouldAllowGetPreviouslySetSerializer()
 
         $expectedSerializer = $this->createSerializerMock();
 
-        //guard
+        // guard
         $this->assertNotSame($producer->getSerializer(), $expectedSerializer);
 
         $producer->setSerializer($expectedSerializer);

pkg/rdkafka/Tests/Spec/RdKafkaSendToAndReceiveFromTopicTest.php

@@ -8,6 +8,7 @@
 
 /**
  * @group functional
+ *
  * @retry 5
  */
 class RdKafkaSendToAndReceiveFromTopicTest extends SendToAndReceiveFromTopicSpec