MassPublisher Class Reference

Inheritance diagram for MassPublisher:

Public Member Functions
	__construct (ExchangeRepository $exchangeRepository, EnvelopeFactory $envelopeFactory, MessageEncoder $messageEncoder, MessageValidator $messageValidator, PublisherConfig $publisherConfig, MessageIdGeneratorInterface $messageIdGenerator)
	publish ($topicName, $data)

Detailed Description

Class MassPublisher used for encoding topic entities to OperationInterface and publish them.

Definition at line 23 of file MassPublisher.php.

Constructor & Destructor Documentation

__construct()

__construct	(	ExchangeRepository	$exchangeRepository,
		EnvelopeFactory	$envelopeFactory,
		MessageEncoder	$messageEncoder,
		MessageValidator	$messageValidator,
		PublisherConfig	$publisherConfig,
		MessageIdGeneratorInterface	$messageIdGenerator
	)

Initialize dependencies.

Parameters

\Magento\Framework\MessageQueue\Bulk\ExchangeRepository	$exchangeRepository
\Magento\Framework\MessageQueue\EnvelopeFactory	$envelopeFactory
\Magento\Framework\MessageQueue\MessageEncoder	$messageEncoder
\Magento\Framework\MessageQueue\MessageValidator	$messageValidator
\Magento\Framework\MessageQueue\Publisher\ConfigInterface	$publisherConfig
\Magento\Framework\MessageQueue\MessageIdGeneratorInterface	$messageIdGenerator

Definition at line 65 of file MassPublisher.php.

      {
        $this->exchangeRepository = $exchangeRepository;
        $this->envelopeFactory = $envelopeFactory;
        $this->messageEncoder = $messageEncoder;
        $this->messageValidator = $messageValidator;
        $this->publisherConfig = $publisherConfig;
        $this->messageIdGenerator = $messageIdGenerator;
    }

Member Function Documentation

publish()

publish	(		$topicName,
			$data
	)

{Publishes a message to a specific queue or exchange.

Parameters

string	$topicName
array | object	$data

Returns

null|mixed

Exceptions

}

Implements PublisherInterface.

Definition at line 84 of file MassPublisher.php.

    {
        $envelopes = [];
        foreach ($data as $message) {
            $this->messageValidator->validate(AsyncConfig::SYSTEM_TOPIC_NAME, $message);
            $message = $this->messageEncoder->encode(AsyncConfig::SYSTEM_TOPIC_NAME, $message);
            $envelopes[] = $this->envelopeFactory->create(
                [
                    'body' => $message,
                    'properties' => [
                        'delivery_mode' => 2,
                        'message_id' => $this->messageIdGenerator->generate($topicName),
                    ]
                ]
            );
        }
        $publisher = $this->publisherConfig->getPublisher($topicName);
        $connectionName = $publisher->getConnection()->getName();
        $exchange = $this->exchangeRepository->getByConnectionName($connectionName);
        $exchange->enqueue($topicName, $envelopes);
        return null;
    }

---

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

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