diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php index 5f0cb9f..49bfe9f 100644 --- a/src/Consumer/Consumer.php +++ b/src/Consumer/Consumer.php @@ -6,6 +6,7 @@ use Closure; use Basis\Nats\Client; +use Basis\Nats\Message\Payload; class Consumer { @@ -154,6 +155,9 @@ public function handle(Closure $handler, Closure $emptyHandler = null, bool $ack return $runtime->processed; } + /** + * @return Payload + */ public function info() { return $this->client->api("CONSUMER.INFO." . $this->getStream() . '.' . $this->getName());