diff --git a/src/Console/Command/ConsumerCommand.php b/src/Console/Command/ConsumerCommand.php index 8d573e7..31dd827 100644 --- 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); }