AmqpReceiver

class AmqpReceiver implements ReceiverInterface

Symfony Messenger приемник для получения сообщений из брокеров AMQP с использованием расширения AMQP PHP.

Методы

	__construct(DecoderInterface $decoder, Connection $connection)
void	receive(callable $handler) Получить некоторые сообщения в данный обработчик.
void	stop() Остановить получение сообщений.

Подробности

__construct(DecoderInterface $decoder, Connection $connection)

Параметры

DecoderInterface	$decoder
Connection	$connection

void receive(callable $handler)

Получить некоторые сообщения в данный обработчик.

У обработчика будет, как аргумент, полученная {@link \Symfony\Component\Messenger\Envelope} содержащая сообщение. Обратите внимание, что эта оболочка может быть null если таймаут получения чего-либо истек.

Параметры

callable

$handler

Возвращаемое значение

void

void stop()

Остановить получение сообщений.

Возвращаемое значение

void

© 2004–2017 Fabien Potencier
Licensed under the MIT License.
https://api.symfony.com/4.1/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.html