ConsumerCommand update

paveljanda · paveljanda · commit 1e4efcad3414 · 2017-05-10T16:38:57.000+02:00
diff --git a/src/Console/Command/ConsumerCommand.php b/src/Console/Command/ConsumerCommand.php
@@ -60,7 +60,8 @@ protected function execute(InputInterface $input, OutputInterface $output): void
 
 		$this->validateInput($consumerName, $secondsToLive, $output); // May exit;
 
-
+		$consumer = $this->consumerFactory->getConsumer($consumerName);
+		$consumer->consumeForSpecifiedTime($secondsToLive);
 	}
 
 

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,8 @@ protected function execute(InputInterface $input, OutputInterface $output): void`
`60`	`60`
`61`	`61`	`$this->validateInput($consumerName, $secondsToLive, $output); // May exit;`
`62`	`62`
`63`		`-`
	`63`	`+ $consumer = $this->consumerFactory->getConsumer($consumerName);`
	`64`	`+ $consumer->consumeForSpecifiedTime($secondsToLive);`
`64`	`65`	`}`
`65`	`66`
`66`	`67`