Merge pull request #567 from rosamarsky/fix-kafka-consuming

[rdkafka] Use default queue as router topic
php-enqueue · Oct 18, 2018 · 0fd466c · 0fd466c
2 parents 607780b + 348e9e4
commit 0fd466c
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 16 deletions.
diff --git a/pkg/enqueue/Client/Driver/RdKafkaDriver.php b/pkg/enqueue/Client/Driver/RdKafkaDriver.php
@@ -1,10 +1,11 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Client\Driver;
 
 use Enqueue\RdKafka\RdKafkaContext;
 use Enqueue\RdKafka\RdKafkaTopic;
-use Interop\Queue\Destination;
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 
@@ -44,14 +45,4 @@ public function setupBroker(LoggerInterface $logger = null): void
             $this->getContext()->createConsumer($queue);
         }
     }
-
-    /**
-     * @return RdKafkaTopic
-     */
-    protected function createRouterTopic(): Destination
-    {
-        return $this->doCreateTopic(
-            $this->createTransportRouterTopicName($this->getConfig()->getRouterTopic(), true)
-        );
-    }
 }
diff --git a/pkg/enqueue/Client/Driver/RedisDriver.php b/pkg/enqueue/Client/Driver/RedisDriver.php
@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\Client\Driver;
 
 use Enqueue\Redis\RedisContext;

diff --git a/pkg/enqueue/Tests/Client/Driver/RdKafkaDriverTest.php b/pkg/enqueue/Tests/Client/Driver/RdKafkaDriverTest.php
@@ -118,11 +118,6 @@ protected function createMessage(): InteropMessage
         return new RdKafkaMessage();
     }
 
-    protected function getRouterTransportName(): string
-    {
-        return 'aprefix.router';
-    }
-
     /**
      * @return Config
      */