MAKS\AmqpAgent\Worker\Publisher::publish

Publishes a message to the default exchange on the default channel of the worker's connection to RabbitMQ server.

Signature

public function publish(string|array|AMQPMessage
        $payload,
            [array
        $parameters = NULL,
            [AMQPChannel
        $_channel = NULL]] )

Parameters

$payload — object: A string of the body of the message or an array of body and properties for the message or a AMQPMessage object.
$parameters — array: [optional] The overrides for the default publish 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

Publisher

Errors/Exceptions

Exception|AMQPChannelClosedException|AMQPConnectionClosedException|AMQPConnectionBlockedException

Defined by Interface

PublisherInterface

Test Coverage

Information

Coverage: 30/30 Lines (100%)
Tests: 5
Passed: 5 (100%)

Tests

[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishRaisesAnExceptionIfUnexpectedParameterIsPassed
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishBatchAndPublishPublishesMessagesToRabbitMQServerAndOverrideParametersTakeEffect
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishPublishesMessagesToRabbitMQServerWithDifferentTypesOfMessages
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishingMessagesToRabbitMQServerViaWorkMethod
[ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testWorkRaisesAnExceptionIfUnexpectedParameterIsPassed