MAKS\AmqpAgent\Worker\ConsumerInterface::consume
Consumes messages from the default channel of the worker's connection to RabbitMQ server.
Signature
Parameters
$callback
—
object
- [optional] The callback that the consumer uses to process the messages.
$variables
—
array
- [optional] The variables that should be passed to the callback.
$parameters
—
array
- [optional] The overrides for the default exchange options of the worker.
$_channel
—
MAKS\AmqpAgent\Worker\AMQPChannel|null
- [optional] The channel that should be used instead of the default worker's channel.
Returns
- ConsumerInterface