From 348e9e454fbff118483c3b83aec36a5ba4a6356c Mon Sep 17 00:00:00 2001
From: Roman Samarsky <rosamarsky@gmail.com>
Date: Thu, 18 Oct 2018 17:58:09 +0300
Subject: [PATCH] fixes https://github.com/php-enqueue/enqueue-dev/issues/557

---
 pkg/enqueue/Client/Driver/RdKafkaDriver.php         | 13 ++-----------
 pkg/enqueue/Client/Driver/RedisDriver.php           |  2 ++
 .../Tests/Client/Driver/RdKafkaDriverTest.php       |  5 -----
 3 files changed, 4 insertions(+), 16 deletions(-)

diff --git a/pkg/enqueue/Client/Driver/RdKafkaDriver.php b/pkg/enqueue/Client/Driver/RdKafkaDriver.php
index ecb711c97..37013bbe5 100644
--- 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
index 641d3bff3..493cb7c96 100644
--- 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
index f3474e78c..659590ba3 100644
--- 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
      */