interface TransportInterface implements ReceiverInterface, SenderInterface

Methods

void
receive(callable $handler)

Receive some messages to the given handler.

void
stop()

Stop receiving some messages.

send(Envelope $envelope)

Sends the given envelope.

Details

in ReceiverInterface at line 27
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

in ReceiverInterface at line 32
void stop()

Stop receiving some messages.

Return Value

void

in SenderInterface at line 28
send(Envelope $envelope)

Sends the given envelope.

Parameters

Envelope $envelope