class StopWhenMemoryUsageIsExceededReceiver implements ReceiverInterface

Methods

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

No description

void
receive(callable $handler)

Receive some messages to the given handler.

void
stop()

Stop receiving some messages.

Details

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

Parameters

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

at line 38
void receive(callable $handler)

Receive some messages to the given handler.

The handler will have, as argument, the received {@link \Symfony\Component\Messenger\Envelope} containing the message. Note that this envelope can be null if the timeout to receive something has expired.

Parameters

callable $handler

Return Value

void

at line 53
void stop()

Stop receiving some messages.

Return Value

void