MAKS\AmqpAgent\Worker\ConsumerInterface::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

ConsumerInterface