Fix CS

Author: andrewmy

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]);

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);

Tests/RdKafkaProducerTest.php

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

Tests/Spec/RdKafkaSendToAndReceiveFromTopicTest.php

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