StopWhenMemoryUsageIsExceededReceiver

__construct(ReceiverInterface $decoratedReceiver, int $memoryLimit, LoggerInterface $logger = null, callable $memoryResolver = null)

Параметры

ReceiverInterface	$decoratedReceiver
int	$memoryLimit
LoggerInterface	$logger
callable	$memoryResolver

void receive(callable $handler)

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

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

Параметры

callable

$handler

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

void

void stop()

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

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

void