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 @@ 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 @@