MAKS\AmqpAgent\Worker\Consumer::wait

Keeps the connection to RabbitMQ server alive as long as the default channel is in used.

Signature

public function wait([array
        $parameters = NULL,
            [AMQPChannel
        $_channel = NULL]] )

Parameters

$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

AMQPOutOfBoundsException|AMQPRuntimeException|AMQPTimeoutException

Defined by Interface

ConsumerInterface

Test Coverage

Information

Coverage: 14/14 Lines (100%)
Tests: 3
Passed: 3 (100%)

Tests

[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumeConsumesMessagesFromRabbitMQServerAndAknowledgesThem
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerViaWorkMethod
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerUsingConfigCallback