fix: Fix wrong sentence and add type on new receiver

Author: Johnmeurt

src/Console/Command/ConsumeCommand.php

@@ -83,7 +83,7 @@ protected function configure(): void
             ->addOption('save', null, InputOption::VALUE_NONE, 'Save failed job.')
             ->addOption('max', null, InputOption::VALUE_REQUIRED, 'The max number of jobs.')
             ->addOption('expire', null, InputOption::VALUE_REQUIRED, 'The worker duration in seconds.')
-            ->addOption('expireWhenEmpty', null, InputOption::VALUE_REQUIRED, 'Stop the worker when the queues are empty for a among of time in seconds.')
+            ->addOption('expireWhenEmpty', null, InputOption::VALUE_REQUIRED, 'Stop the worker when the queues are empty for an among of time in seconds.')
             ->addOption('stopWhenEmpty', null, InputOption::VALUE_NONE, 'Stop the worker if the queues are empty.')
             ->addOption('stopOnError', null, InputOption::VALUE_NONE, 'Stop the worker if error occurs.')
             ->addOption('logger', null, InputOption::VALUE_REQUIRED, 'The logger to use "stdout", "null", or "default".', "default")

src/Consumer/Receiver/LimitTimeWhenEmptyReceiver.php

@@ -14,24 +14,9 @@ class LimitTimeWhenEmptyReceiver implements ReceiverInterface
 {
     use DelegateHelper;
 
-    /**
-     * Time limit in second
-     *
-     * @var int
-     */
-    private $limit;
-
-    /**
-     * The end time
-     *
-     * @var int
-     */
-    private $endTime;
-
-    /**
-     * @var LoggerInterface
-     */
-    private $logger;
+    private int $limit;
+    private ?int $endTime;
+    private ?LoggerInterface $logger;
 
     /**
      * TimeLimiterMiddlewareReceiver constructor.

tests/Consumer/Receiver/Builder/ReceiverBuilderTest.php

@@ -9,6 +9,7 @@
 use Bdf\Queue\Consumer\Receiver\BenchReceiver;
 use Bdf\Queue\Consumer\Receiver\Binder\BinderReceiver;
 use Bdf\Queue\Consumer\Receiver\Binder\ClassNameBinder;
+use Bdf\Queue\Consumer\Receiver\LimitTimeWhenEmptyReceiver;
 use Bdf\Queue\Consumer\Receiver\MemoryLimiterReceiver;
 use Bdf\Queue\Consumer\Receiver\MessageCountLimiterReceiver;
 use Bdf\Queue\Consumer\Receiver\MessageLoggerReceiver;
@@ -573,6 +574,22 @@ public function test_expire()
         );
     }
 
+    /**
+     *
+     */
+    public function test_expire_when_empty()
+    {
+        $this->builder->expireWhenEmpty(10);
+
+        $this->assertEquals(
+            new ReceiverPipeline([
+                new LimitTimeWhenEmptyReceiver(10, new LoggerProxy(new NullLogger())),
+                new ProcessorReceiver(new JobHintProcessorResolver($this->container->get(InstantiatorInterface::class))),
+            ]),
+            $this->builder->build()
+        );
+    }
+
     /**
      *
      */