Merge pull request #76 from MilanPala/return-types

Added return types according to the Symfony Commands
Kdyby · Aug 19, 2021 · 34e519f · 34e519f
2 parents 6501297 + 533b862
commit 34e519f
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 5 deletions.
diff --git a/src/Kdyby/RabbitMq/Command/BaseConsumerCommand.php b/src/Kdyby/RabbitMq/Command/BaseConsumerCommand.php
@@ -84,9 +84,11 @@ protected function initialize(InputInterface $input, OutputInterface $output): v
 		}
 	}
 
-	protected function execute(InputInterface $input, OutputInterface $output): void
+	protected function execute(InputInterface $input, OutputInterface $output): int
 	{
 		$this->consumer->consume($this->amount);
+
+		return \Symfony\Component\Console\Command\Command::SUCCESS;
 	}
 
 	/**

diff --git a/src/Kdyby/RabbitMq/Command/PurgeConsumerCommand.php b/src/Kdyby/RabbitMq/Command/PurgeConsumerCommand.php
@@ -44,7 +44,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 		$consumer = $this->connection->getConsumer($input->getArgument('name'));
 		$consumer->purge();
 
-		return 0;
+		return \Symfony\Component\Console\Command\Command::SUCCESS;
 	}
 
 }
diff --git a/src/Kdyby/RabbitMq/Command/RpcServerCommand.php b/src/Kdyby/RabbitMq/Command/RpcServerCommand.php
@@ -33,7 +33,7 @@ protected function configure(): void
 	 *
 	 * @throws \InvalidArgumentException When the number of messages to consume is less than 0
 	 */
-	protected function execute(InputInterface $input, OutputInterface $output): void
+	protected function execute(InputInterface $input, OutputInterface $output): int
 	{
 		\define('AMQP_DEBUG', (bool) $input->getOption('debug'));
 
@@ -45,6 +45,8 @@ protected function execute(InputInterface $input, OutputInterface $output): void
 
 		$rpcServer = $this->connection->getRpcServer($input->getArgument('name'));
 		$rpcServer->start($amount);
+
+		return \Symfony\Component\Console\Command\Command::SUCCESS;
 	}
 
 }
diff --git a/src/Kdyby/RabbitMq/Command/SetupFabricCommand.php b/src/Kdyby/RabbitMq/Command/SetupFabricCommand.php
@@ -26,7 +26,7 @@ protected function configure(): void
 			->addOption('debug', 'd', InputOption::VALUE_NONE, 'Enable Debugging');
 	}
 
-	protected function execute(InputInterface $input, OutputInterface $output): void
+	protected function execute(InputInterface $input, OutputInterface $output): int
 	{
 		if (\defined('AMQP_DEBUG') === FALSE) {
 			\define('AMQP_DEBUG', (bool) $input->getOption('debug'));
@@ -46,6 +46,8 @@ protected function execute(InputInterface $input, OutputInterface $output): void
 				$service->setupFabric();
 			}
 		}
+
+		return \Symfony\Component\Console\Command\Command::SUCCESS;
 	}
 
 }
diff --git a/src/Kdyby/RabbitMq/Command/StdInProducerCommand.php b/src/Kdyby/RabbitMq/Command/StdInProducerCommand.php
@@ -30,7 +30,7 @@ protected function configure(): void
 	/**
 	 * Executes the current command.
 	 */
-	protected function execute(InputInterface $input, OutputInterface $output): void
+	protected function execute(InputInterface $input, OutputInterface $output): int
 	{
 		\define('AMQP_DEBUG', (bool) $input->getOption('debug'));
 
@@ -42,6 +42,8 @@ protected function execute(InputInterface $input, OutputInterface $output): void
 		}
 
 		$producer->publish(\serialize($data));
+
+		return \Symfony\Component\Console\Command\Command::SUCCESS;
 	}
 
 }