MAKS\AmqpAgent\Worker\Consumer::get

Gets a message object from a channel, direct access to a queue.

Signature

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

Parameters

$_channel — PhpAmqpLib\Channel\AMQPChannel: The channel that should be used.
$parameters — array: [optional] The overrides for the default get options.

Returns

AMQPMessage|null

Errors/Exceptions

AMQPTimeoutException

Defined by Interface

ConsumerInterface

Test Coverage

Information

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

Tests

[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testGetGetsAMessageFromRabbitMQServer
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testGetGetsMessagesFromRabbitMQServerAndUnaknowledgesThem
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testRejectRejectsAMessageAndRedeiliversMessagesToRabbitMQServer