MAKS\AmqpAgent\Worker\Consumer::consume

Consumes messages from the default channel of the worker's connection to RabbitMQ server.

Signature

public function consume([callback|array|string|null
        $callback = NULL,
            [array
        $variables = NULL,
            [array
        $parameters = NULL,
            [AMQPChannel
        $_channel = NULL]]]] )

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

Consumer

Errors/Exceptions

CallbackDoesNotExistException|AMQPTimeoutException

Defined by Interface

ConsumerInterface

Test Coverage

Information

Coverage: 36/36 Lines (100%)
Tests: 8
Passed: 8 (100%)

Tests

[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumeConsumesMessagesFromRabbitMQServerAndAknowledgesThem
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumeRaisesAnExceptionIfInvalidCallbackIsPassed
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testWaitForAllWaitsForMultipleChannelAndReturnsSelf
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerViaWorkMethod
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testWorkRaisesAnExceptionIfUnexpectedParameterIsPassed
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testCancelCancelsAConsumerAndRedeiliversMessagesToRabbitMQServer
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testRecoverRedeliversAllUnaknowledgeMessagesToRabbitMQServer
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerUsingConfigCallback