diff --git a/src/Consumer/Configuration.php b/src/Consumer/Configuration.php index 2389025..a5f771d 100644 --- a/src/Consumer/Configuration.php +++ b/src/Consumer/Configuration.php @@ -159,6 +159,18 @@ public function setMaxAckPending(int $maxAckPending): self return $this; } + public function setMaxDeliver(int $maxDeliver): self + { + $this->maxDeliver = $maxDeliver; + return $this; + } + + public function setMaxWaiting(int $maxWaiting): self + { + $this->maxWaiting = $maxWaiting; + return $this; + } + public function setName(string $name): self { if ($this->isEphemeral()) {