AirLay backend

RabbitmqHelper
in package

Table of Contents

CONFIRM_TIMEOUT  = 5
DELAY_QUEUE_SUFFIX  = '__delay'
factoryForDelayQueue()  : string
Generate name for helper queue with delayed messages.
makeBasicConsumer()  : AMQPChannel
Init consumer of queue with given callback.
publishToDelayQueue()  : bool
Publish message directly to the delay queue.
publishToQueue()  : bool
Publish message directly to the basic queue.

Constants

Methods

factoryForDelayQueue()

Generate name for helper queue with delayed messages.

public static factoryForDelayQueue(string $name) : string
Parameters
$name : string

Main queue name

Return values
string —

Delayed queue name

makeBasicConsumer()

Init consumer of queue with given callback.

public static makeBasicConsumer(AMQPStreamConnection $connection, string $queue, callable $callback[, int $prefetchCount = 1 ]) : AMQPChannel
Parameters
$connection : AMQPStreamConnection
$queue : string
$callback : callable
$prefetchCount : int = 1

(only for Matomo)

Return values
AMQPChannel —

publishToDelayQueue()

Publish message directly to the delay queue.

public static publishToDelayQueue(AMQPStreamConnection $connection, string $queue,  $data[, bool $isConfirmRequired = true ]) : bool
Parameters
$connection : AMQPStreamConnection
$queue : string
$data :
$isConfirmRequired : bool = true

Wait for confirmation from the server

Tags
see
RabbitmqHelper::publishToQueue()
Return values
bool —

True if message was published successfully

publishToQueue()

Publish message directly to the basic queue.

public static publishToQueue(AMQPStreamConnection $connection, string $queue,  $data[, bool $isConfirmRequired = true ]) : bool
Parameters
$connection : AMQPStreamConnection
$queue : string
$data :
$isConfirmRequired : bool = true

Wait for confirmation from the server

Return values
bool —

True if message was published successfully

Search results