fixes php-enqueue#557

rosamarsky · rosamarsky · commit 348e9e454fbf · 2018-10-18T17:58:09.000+03:00
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
      */
