Symfony\Component\Messenger\Transport\AmqpExt\AmqpTransport

class AmqpTransport implements TransportInterface

Methods

__construct(Connection $connection, SerializerInterface $serializer = null)

No description

void

receive(callable $handler)

Receive some messages to the given handler.

void

stop()

Stop receiving some messages.

Envelope

send(Envelope $envelope)

Sends the given envelope.

Details

`__construct(Connection $connection, SerializerInterface $serializer = null)`

Parameters

Connection	$connection
SerializerInterface	$serializer

`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

`void stop()`

Stop receiving some messages.

Return Value

void

`Envelope send(Envelope $envelope)`

Sends the given envelope.

Parameters

Envelope

$envelope

Return Value

Envelope