From da4331127b2b758cc3ca7ed9cab4d7f528a04d84 Mon Sep 17 00:00:00 2001 From: Konstantin Grachev Date: Mon, 25 Jan 2021 03:27:04 +0300 Subject: [PATCH] Refactoring: Move delay parameter as last in Producer::dpub --- README.md | 4 ++-- src/Producer.php | 4 ++-- tests/NsqTest.php | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/README.md b/README.md index 50401cd..c48b19d 100644 --- a/README.md +++ b/README.md @@ -44,7 +44,7 @@ Usage ### Publish ```php -use Nsq\Producer; +use Nsq\Producer;use function Amp\Promise\timeout; $producer = new Producer(address: 'tcp://nsqd:4150'); @@ -58,7 +58,7 @@ $producer->mpub('topic', [ ]); // Publish a deferred message to a topic -$producer->dpub('topic', 5000, 'Deferred message'); +$producer->dpub('topic', 'Deferred message', delay: 5000); ``` ### Subscription diff --git a/src/Producer.php b/src/Producer.php index f20bcbd..74c3f03 100644 --- a/src/Producer.php +++ b/src/Producer.php @@ -37,8 +37,8 @@ final class Producer extends Connection /** * @psalm-suppress PossiblyFalseOperand */ - public function dpub(string $topic, int $deferTime, string $body): void + public function dpub(string $topic, string $body, int $delay): void { - $this->command('DPUB', [$topic, $deferTime], $body)->response()->okOrFail(); + $this->command('DPUB', [$topic, $delay], $body)->response()->okOrFail(); } } diff --git a/tests/NsqTest.php b/tests/NsqTest.php index 18a38d8..fbecdd9 100644 --- a/tests/NsqTest.php +++ b/tests/NsqTest.php @@ -63,7 +63,7 @@ final class NsqTest extends TestCase self::assertSame('Second mpub message.', $message->body); $message->finish(); - $producer->dpub(__FUNCTION__, 2000, 'Deferred message.'); + $producer->dpub(__FUNCTION__, 'Deferred message.', 2000); $generator->next(); /** @var null|Message $message */