consumer configuration tests

basis-company · Dec 23, 2024 · 88dabed · 88dabed
1 parent 4221cb7
commit 88dabed
Showing 1 changed file with 36 additions and 0 deletions.
diff --git a/tests/Functional/StreamTest.php b/tests/Functional/StreamTest.php
@@ -19,6 +19,42 @@ class StreamTest extends FunctionalTestCase
 
     private bool $empty;
 
+    public function testInvalidAckPolicy()
+    {
+        $this->expectExceptionMessage("Invalid ack policy: fast");
+
+        $this->createClient()
+            ->getApi()
+            ->getStream('acking')
+            ->getConsumer('tester')
+            ->getConfiguration()
+            ->setAckPolicy('fast');
+    }
+
+    public function testInvalidDeliverPolicy()
+    {
+        $this->expectExceptionMessage("Invalid deliver policy: turtle");
+
+        $this->createClient()
+            ->getApi()
+            ->getStream('acking')
+            ->getConsumer('tester')
+            ->getConfiguration()
+            ->setDeliverPolicy('turtle');
+    }
+
+    public function testInvalidReplayPolicy()
+    {
+        $this->expectExceptionMessage("Invalid replay policy: fast");
+
+        $this->createClient()
+            ->getApi()
+            ->getStream('acking')
+            ->getConsumer('tester')
+            ->getConfiguration()
+            ->setReplayPolicy('fast');
+    }
+
     public function testNack()
     {
         $client = $this->createClient();