add runhandler

Author: alexander-schranz

src/Command/RunHandlerCommand.php

@@ -0,0 +1,48 @@
+<?php
+
+namespace Task\TaskBundle\Command;
+
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Task\Handler\RegistryInterface;
+use Task\SchedulerInterface;
+
+/**
+ * Run pending tasks.
+ *
+ * @author @wachterjohannes <johannes.wachter@massiveart.com>
+ */
+class RunHandlerCommand extends Command
+{
+    /**
+     * @var RegistryInterface
+     */
+    private $registry;
+
+    public function __construct(RegistryInterface $registry)
+    {
+        parent::__construct('task:run:handler');
+
+        $this->registry = $registry;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function configure()
+    {
+        $this->setDescription('Run pending tasks')
+            ->addArgument('handler', InputArgument::REQUIRED)
+            ->addArgument('workload', InputArgument::OPTIONAL);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $this->registry->run($input->getArgument('handler'), $input->getArgument('workload'));
+    }
+}

src/Resources/config/command.xml

@@ -9,6 +9,12 @@
             <tag name="console.command"/>
         </service>
 
+        <service id="task.command.run.handler" class="Task\TaskBundle\Command\RunHandlerCommand">
+            <argument type="service" id="task.handler_registry"/>
+
+            <tag name="console.command"/>
+        </service>
+
         <service id="task.command.schedule_task" class="Task\TaskBundle\Command\ScheduleTaskCommand">
             <argument type="service" id="task.scheduler"/>