MassConsumer Class Reference

Inheritance diagram for MassConsumer:

Public Member Functions
	__construct (CallbackInvoker $invoker, ResourceConnection $resource, MessageController $messageController, ConsumerConfigurationInterface $configuration, OperationProcessorFactory $operationProcessorFactory, LoggerInterface $logger)
	process ($maxNumberOfMessages=null)

Detailed Description

Class Consumer used to process OperationInterface messages.

@SuppressWarnings(PHPMD.CouplingBetweenObjects)

Definition at line 29 of file MassConsumer.php.

Constructor & Destructor Documentation

__construct()

__construct	(	CallbackInvoker	$invoker,
		ResourceConnection	$resource,
		MessageController	$messageController,
		ConsumerConfigurationInterface	$configuration,
		OperationProcessorFactory	$operationProcessorFactory,
		LoggerInterface	$logger
	)

Initialize dependencies.

Parameters

CallbackInvoker	$invoker
ResourceConnection	$resource
MessageController	$messageController
ConsumerConfigurationInterface	$configuration
OperationProcessorFactory	$operationProcessorFactory
LoggerInterface	$logger

Definition at line 71 of file MassConsumer.php.

      {
        $this->invoker = $invoker;
        $this->resource = $resource;
        $this->messageController = $messageController;
        $this->configuration = $configuration;
        $this->operationProcessor = $operationProcessorFactory->create([
            'configuration' => $configuration
        ]);
        $this->logger = $logger;
    }

Member Function Documentation

process()

process

(

$maxNumberOfMessages = null

)

{Connects to a queue, consumes a message on the queue, and invoke a method to process the message contents.

Parameters

int | null

$maxNumberOfMessages

if not specified - process all queued incoming messages and terminate, otherwise terminate execution after processing the specified number of messages

Returns

void

}

Implements ConsumerInterface.

Definition at line 92 of file MassConsumer.php.

    {
        $queue = $this->configuration->getQueue();

        if (!isset($maxNumberOfMessages)) {
            $queue->subscribe($this->getTransactionCallback($queue));
        } else {
            $this->invoker->invoke($queue, $maxNumberOfMessages, $this->getTransactionCallback($queue));
        }
    }

---

The documentation for this class was generated from the following file:

• vendor/magento/module-asynchronous-operations/Model/MassConsumer.php