Merge pull request #4 from MammatusPHP/app-should-close-consumer-on-s…

…ignals

App should close consumer on signals

src/App.php

@@ -52,6 +52,8 @@ public function run(string $className): int
 
         await(all($promises));
 
+        $this->context->close();
+
         return 0;
     }
 

src/LifeCycle/CloseContext.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Mammatus\Queue\LifeCycle;
+
+use Interop\Queue\Context;
+use Mammatus\LifeCycleEvents\Shutdown;
+use WyriHaximus\Broadcast\Contracts\Listener;
+
+final class CloseContext implements Listener
+{
+    public function __construct(
+        private readonly Context $context,
+    ) {
+    }
+
+    public function stop(Shutdown $event): void
+    {
+        $this->context->close();
+    }
+}