MAKS\AmqpAgent\Worker\Consumer::qos
Specifies the quality of service on the default channel of the worker's connection to RabbitMQ server.
Signature
public function qos([array
$parameters = NULL,
[AMQPChannel
$_channel = NULL]] )
Parameters
$parameters
—
array
- [optional] The overrides for the default quality of service 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
Defined by Interface
ConsumerInterface
Test Coverage
Information
- Coverage: 11/11 Lines (100%)
- Tests: 10
- Passed: 10 (100%)
Tests
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testQosReturnsSelfAndOverrideParametersTakeEffect
- [ 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::testGetGetsAMessageFromRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testCancelCancelsAConsumerAndRedeiliversMessagesToRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testRecoverRedeliversAllUnaknowledgeMessagesToRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerUsingConfigCallback