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 */