diff --git a/src/Stream/Configuration.php b/src/Stream/Configuration.php index 6d87c27..06ad850 100644 --- a/src/Stream/Configuration.php +++ b/src/Stream/Configuration.php @@ -23,6 +23,7 @@ class Configuration private ?int $maxMessageSize = null; private ?int $maxMessagesPerSubject = null; private ?string $description = null; + private ?bool $allowDirect = null; public function __construct( public readonly string $name @@ -193,6 +194,17 @@ public function setSubjects(array $subjects): self return $this; } + public function getAllowDirect(): ?bool + { + return $this->allowDirect; + } + + public function setAllowDirect(?bool $allowDirect): self + { + $this->allowDirect = $allowDirect; + return $this; + } + public function toArray(): array { $config = [ @@ -211,6 +223,7 @@ public function toArray(): array 'retention' => $this->getRetentionPolicy(), 'storage' => $this->getStorageBackend(), 'subjects' => $this->getSubjects(), + 'allow_direct' => $this->getAllowDirect(), ]; foreach ($config as $k => $v) {