Fix DefaultConfigFactory::createRunner() and examples

Author: Eugene Leonovich

examples/client/queue.php

@@ -1,5 +1,6 @@
 <?php
 
-$factory = new Tarantool\JobQueue\DefaultConfigFactory();
-
-return $factory->createQueue('foobar', $factory->createClient('tcp://127.0.0.1:3301'));
+return (new Tarantool\JobQueue\DefaultConfigFactory())
+    ->setConnectionUri('tcp://127.0.0.1:3301')
+    ->setQueueName('foobar')
+    ->createQueue();

examples/config.php

@@ -18,7 +18,7 @@ public function __construct(Handler $handler)
                 $this->handler = $handler;
             }
 
-            public function handle(Task $task, Queue $queue)
+            public function handle(Task $task, Queue $queue): void
             {
                 $this->handler->handle($task, $queue);
 

examples/single_executor.php

@@ -6,7 +6,7 @@
 
 return new class implements Executor
 {
-    public function execute($payload, Queue $queue)
+    public function execute($payload, Queue $queue): void
     {
         // do something with the payload
     }

src/DefaultConfigFactory.php

@@ -73,14 +73,14 @@ public function setExecutorsConfigFile(string $configFile): self
         return $this;
     }
 
-    public function createRunner(string $executorsConfigFile = null): Runner
+    public function createRunner(): Runner
     {
         return new ParallelRunner(
             $this->createQueue(),
             $this->createSuccessHandler(),
             $this->createFailureHandler(),
             $this->createLogger(),
-            $executorsConfigFile
+            $this->executorsConfigFile
         );
     }
 

src/Executor/ExecutorChain.php

@@ -31,6 +31,8 @@ public function execute($payload, Queue $queue): void
         foreach ($this->executors as $executor) {
             try {
                 $executor->execute($payload, $queue);
+
+                return;
             } catch (BadPayloadException $e) {
                 // try next executor
             }