class QueueFactory implements ContainerAwareInterface (View source)

Defines the queue factory.

Traits

ContainerAwareTrait

Properties

protected array $queues

Instantiated queues, keyed by name.

protected Settings $settings

The settings object.

Methods

__construct(Settings $settings)

Constructs a queue factory.

get(string $name, bool $reliable = FALSE)

Constructs a new queue.

Details

__construct(Settings $settings)

Constructs a queue factory.

Parameters

Settings $settings

QueueInterface get(string $name, bool $reliable = FALSE)

Constructs a new queue.

Parameters

string $name

The name of the queue to work with.

bool $reliable

(optional) TRUE if the ordering of items and guaranteeing every item executes at least once is important, FALSE if scalability is the main concern. Defaults to FALSE.

Return Value

QueueInterface

A queue implementation for the given name.