Publisher Class Reference

Inheritance diagram for Publisher:

Data Structures
class	ConfigTest
class	DeprecatedConfigTest

Public Member Functions
	__construct (ExchangeRepository $exchangeRepository, EnvelopeFactory $envelopeFactory, MessageQueueConfig $messageQueueConfig, MessageEncoder $messageEncoder, MessageValidator $messageValidator)
	publish ($topicName, $data)

Detailed Description

A MessageQueue Publisher to handle publishing a message.

Definition at line 15 of file Publisher.php.

Constructor & Destructor Documentation

__construct()

__construct	(	ExchangeRepository	$exchangeRepository,
		EnvelopeFactory	$envelopeFactory,
		MessageQueueConfig	$messageQueueConfig,
		MessageEncoder	$messageEncoder,
		MessageValidator	$messageValidator
	)

Initialize dependencies.

Parameters

ExchangeRepository	$exchangeRepository
EnvelopeFactory	$envelopeFactory
MessageQueueConfig	$messageQueueConfig
MessageEncoder	$messageEncoder
MessageValidator	$messageValidator

Definition at line 61 of file Publisher.php.

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

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 77 of file Publisher.php.

    {
        $this->messageValidator->validate($topicName, $data);
        $data = $this->messageEncoder->encode($topicName, $data);
        $envelope = $this->envelopeFactory->create(
            [
                'body' => $data,
                'properties' => [
                    'delivery_mode' => 2,
                    'message_id' => md5(uniqid($topicName))
                ]
            ]
        );
        $connectionName = $this->getPublisherConfig()->getPublisher($topicName)->getConnection()->getName();
        $connectionName = ($connectionName === 'amqp' && !$this->isAmqpConfigured()) ? 'db' : $connectionName;
        $exchange = $this->exchangeRepository->getByConnectionName($connectionName);
        $exchange->enqueue($topicName, $envelope);
        return null;
    }

---

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

• vendor/magento/framework-message-queue/Publisher.php