diff --git a/pkg/enqueue/Client/Producer.php b/pkg/enqueue/Client/Producer.php index b3066e543..a3dfacf15 100644 --- a/pkg/enqueue/Client/Producer.php +++ b/pkg/enqueue/Client/Producer.php @@ -6,7 +6,7 @@ use Enqueue\Util\JSON; use Enqueue\Util\UUID; -class Producer implements ProducerInterface, ProducerV2Interface +class Producer implements ProducerInterface { /** * @var DriverInterface diff --git a/pkg/enqueue/Client/ProducerInterface.php b/pkg/enqueue/Client/ProducerInterface.php index bc8426704..2fc829eb2 100644 --- a/pkg/enqueue/Client/ProducerInterface.php +++ b/pkg/enqueue/Client/ProducerInterface.php @@ -20,17 +20,4 @@ public function sendEvent($topic, $message); * @return Promise|null the promise is returned if needReply argument is true */ public function sendCommand($command, $message, $needReply = false); - - /** - * @deprecated use sendEvent method. - * - * Sends a message to a topic. There are some message processor may be subscribed to a topic. - * - * @param string $topic - * @param string|array|Message $message - * - * @throws \Enqueue\Psr\Exception - if the producer fails to send - * the message due to some internal error - */ - public function send($topic, $message); } diff --git a/pkg/enqueue/Client/ProducerV2Interface.php b/pkg/enqueue/Client/ProducerV2Interface.php deleted file mode 100644 index c661f0c47..000000000 --- a/pkg/enqueue/Client/ProducerV2Interface.php +++ /dev/null @@ -1,12 +0,0 @@ -