AmqpTransport

__construct(EncoderInterface $encoder, DecoderInterface $decoder, Connection $connection)

Параметры

EncoderInterface	$encoder
DecoderInterface	$decoder
Connection	$connection

void receive(callable $handler)

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

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

Параметры

callable

$handler

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

void

void stop()

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

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

void

send(Envelope $envelope)

Отправить указанный конверт.

Параметры

Envelope

$envelope