StopWhenTimeLimitIsReachedReceiver

__construct(ReceiverInterface $decoratedReceiver, int $timeLimitInSeconds, LoggerInterface $logger = null)

Параметры

ReceiverInterface	$decoratedReceiver
int	$timeLimitInSeconds
LoggerInterface	$logger

void receive(callable $handler)

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

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

Параметры

callable

$handler

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

void

void stop()

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

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

void