Skip to content

Commit

Permalink
Update Consumer.php
Browse files Browse the repository at this point in the history
  • Loading branch information
ro0NL authored Nov 23, 2023
1 parent 31363bd commit 947915f
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions src/Consumer/Consumer.php
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

use Closure;
use Basis\Nats\Client;
use Basis\Nats\Message\Payload;

class Consumer
{
Expand Down Expand Up @@ -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());
Expand Down

0 comments on commit 947915f

Please sign in to comment.