MAKS\AmqpAgent\Worker\Consumer::waitForAll

Tries to keep the connection to RabbitMQ server alive as long as there are channels in used (default or not).

Signature

public function waitForAll([array
        $parameters = NULL,
            [AMQPStreamConnection
        $_connection = NULL]] )

Parameters

$parameters — array: [optional] The overrides for the default exchange options of the worker.
$_connection — MAKS\AmqpAgent\Worker\AMQPStreamConnection|null: [optional] The connection that should be used instead of the default worker's connection.

Returns

Consumer

Errors/Exceptions

AMQPOutOfBoundsException|AMQPRuntimeException|AMQPTimeoutException

Defined by Interface

ConsumerInterface

Test Coverage

Information

Coverage: 23/24 Lines (95.833333333333%)
Tests: 1
Passed: 1 (100%)

Tests

[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testWaitForAllWaitsForMultipleChannelAndReturnsSelf