MAKS\AmqpAgent\Worker\Consumer::recover

Redelivers unacknowledged messages

Signature

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

Parameters

$_channel — PhpAmqpLib\Channel\AMQPChannel

The channel that should be used.




$parameters — array

[optional] The overrides for the default recover options.




Returns

mixed

Errors/Exceptions

AMQPTimeoutException

Defined by Interface

ConsumerInterface

Test Coverage

Information

• Coverage: 4/4 Lines (100%)
• Tests: 1
• Passed: 1 (100%)

Tests

• [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testRecoverRedeliversAllUnaknowledgeMessagesToRabbitMQServer