1. class
  2. Symfony
  3. \
  4. Component
  5. \
  6. Messenger
  7. \
  8. Transport
  9. \
  10. AmqpExt
  11. \
  12. AmqpReceiver

AmqpReceiver

class AmqpReceiver implements ReceiverInterface

Symfony Messenger receiver to get messages from AMQP brokers using PHP's AMQP extension.

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.

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