kafka transport

ASKozienko · ASKozienko · commit 755eb6f39ff8 · 2017-07-14T12:11:08.000+03:00
diff --git a/pkg/rdkafka/RdKafkaConnectionFactory.php b/pkg/rdkafka/RdKafkaConnectionFactory.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\PsrConnectionFactory;
diff --git a/pkg/rdkafka/RdKafkaConsumer.php b/pkg/rdkafka/RdKafkaConsumer.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\InvalidMessageException;
diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\InvalidDestinationException;
diff --git a/pkg/rdkafka/RdKafkaMessage.php b/pkg/rdkafka/RdKafkaMessage.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\PsrMessage;
diff --git a/pkg/rdkafka/RdKafkaProducer.php b/pkg/rdkafka/RdKafkaProducer.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\InvalidDestinationException;
diff --git a/pkg/rdkafka/RdKafkaTopic.php b/pkg/rdkafka/RdKafkaTopic.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\PsrQueue;
diff --git a/pkg/rdkafka/Tests/RdKafkaConnectionFactoryTest.php b/pkg/rdkafka/Tests/RdKafkaConnectionFactoryTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests;
 
 use Enqueue\RdKafka\RdKafkaConnectionFactory;
@@ -43,7 +44,7 @@ public function testShouldBeExpectedDefaultConfig()
             'global' => [
                 'group.id' => 'group-id',
                 'metadata.broker.list' => 'localhost:9092',
-            ]
+            ],
         ], $config);
     }
 
@@ -60,7 +61,7 @@ public function testShouldBeExpectedDefaultDsnConfig()
             'global' => [
                 'group.id' => 'group-id',
                 'metadata.broker.list' => 'localhost:9092',
-            ]
+            ],
         ], $config);
     }
 
@@ -85,7 +86,7 @@ public static function provideConfigs()
                 'global' => [
                     'metadata.broker.list' => 'theHost:1234',
                     'group.id' => 'group-id',
-                ]
+                ],
             ],
         ];
 
@@ -94,13 +95,13 @@ public static function provideConfigs()
                 'global' => [
                     'metadata.broker.list' => 'theHost:1234',
                     'group.id' => 'group-id',
-                ]
+                ],
             ],
             [
                 'global' => [
                     'metadata.broker.list' => 'theHost:1234',
                     'group.id' => 'group-id',
-                ]
+                ],
             ],
         ];
     }
diff --git a/pkg/rdkafka/Tests/RdKafkaConsumerTest.php b/pkg/rdkafka/Tests/RdKafkaConsumerTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests;
 
 use Enqueue\RdKafka\RdKafkaConsumer;
diff --git a/pkg/rdkafka/Tests/RdKafkaContextTest.php b/pkg/rdkafka/Tests/RdKafkaContextTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests;
 
 use Enqueue\Null\NullQueue;
diff --git a/pkg/rdkafka/Tests/RdKafkaMessageTest.php b/pkg/rdkafka/Tests/RdKafkaMessageTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests;
 
 use Enqueue\RdKafka\RdKafkaMessage;
diff --git a/pkg/rdkafka/Tests/RdKafkaProducerTest.php b/pkg/rdkafka/Tests/RdKafkaProducerTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests;
 
 use Enqueue\Null\NullMessage;
diff --git a/pkg/rdkafka/Tests/RdKafkaTopicTest.php b/pkg/rdkafka/Tests/RdKafkaTopicTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests;
 
 use Enqueue\RdKafka\RdKafkaTopic;
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaConnectionFactoryTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaConnectionFactoryTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests\Spec;
 
 use Enqueue\RdKafka\RdKafkaConnectionFactory;
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaContextTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaContextTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests\Spec;
 
 use Enqueue\RdKafka\RdKafkaContext;
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaMessageTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaMessageTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests\Spec;
 
 use Enqueue\RdKafka\RdKafkaMessage;
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaQueueTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaQueueTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests\Spec;
 
 use Enqueue\RdKafka\RdKafkaTopic;
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaSendToAndReceiveFromTopicTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaSendToAndReceiveFromTopicTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests\Spec;
 
 use Enqueue\RdKafka\RdKafkaConnectionFactory;
@@ -10,22 +11,6 @@
  */
 class RdKafkaSendToAndReceiveFromTopicTest extends SendToAndReceiveFromTopicSpec
 {
-    protected function createContext()
-    {
-        $config = [
-            'global' => [
-                'group.id' => uniqid('', true),
-                'metadata.broker.list' => getenv('RDKAFKA_HOST').':'.getenv('RDKAFKA_PORT'),
-                'enable.auto.commit' => 'false',
-            ],
-            'topic' => [
-                'auto.offset.reset' => 'beginning',
-            ]
-        ];
-
-        return (new RdKafkaConnectionFactory($config))->createContext();
-    }
-
     public function test()
     {
         $context = $this->createContext();
@@ -45,4 +30,20 @@ public function test()
 
         $this->assertSame($expectedBody, $message->getBody());
     }
+
+    protected function createContext()
+    {
+        $config = [
+            'global' => [
+                'group.id' => uniqid('', true),
+                'metadata.broker.list' => getenv('RDKAFKA_HOST').':'.getenv('RDKAFKA_PORT'),
+                'enable.auto.commit' => 'false',
+            ],
+            'topic' => [
+                'auto.offset.reset' => 'beginning',
+            ],
+        ];
+
+        return (new RdKafkaConnectionFactory($config))->createContext();
+    }
 }
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaTopicTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaTopicTest.php
@@ -1,4 +1,5 @@
 <?php
+
 namespace Enqueue\RdKafka\Tests\Spec;
 
 use Enqueue\RdKafka\RdKafkaTopic;

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`<?php`
	`2`	`+`
`2`	`3`	`namespace Enqueue\RdKafka;`
`3`	`4`
`4`	`5`	`use Interop\Queue\PsrConnectionFactory;`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`<?php`
	`2`	`+`
`2`	`3`	`namespace Enqueue\RdKafka\Tests;`
`3`	`4`
`4`	`5`	`use Enqueue\RdKafka\RdKafkaConsumer;`