ConsumerRunner.php

<?php declare(strict_types = 1);

namespace Fapi\RabbitMQ;

use Gamee\RabbitMQ\Consumer\ConsumerFactory;
use Nette\DI\Container;

class ConsumerRunner
{

	/** @var Container */
	private $container;

	public function __construct(Container $container)
	{
		$this->container = $container;
	}

	public function run(string $consumerServiceName, int $messagesToConsume, ?int $maxRuntime = null): int
	{
		/** @var ConsumerFactory $consumerFactory */
		$consumerFactory = $this->container->getByType(ConsumerFactory::class);
		$consumer = $consumerFactory->getConsumer($consumerServiceName);
		$consumer->consume($maxRuntime, $messagesToConsume);

		return 0;
	}

}