Static queue implementation.

This allows "undelayed" variants of processes relying on the Queue interface. The queue data resides in memory. It should only be used for items that will be queued and dequeued within a given page request.

Hierarchy

Expanded class hierarchy of MemoryQueue

Related topics

File

core/modules/system/system.queue.inc, line 294
Queue functionality.

Members

Contains filters are case sensitive
Name Modifierssort descending Type Description
MemoryQueue::$queue protected property The queue data.
MemoryQueue::$id_sequence protected property Counter for item ids.
MemoryQueue::__construct public function Start working with a queue.
MemoryQueue::createItem public function Add a queue item and store it directly to the queue. Overrides BackdropQueueInterface::createItem
MemoryQueue::numberOfItems public function Retrieve the number of items in the queue. Overrides BackdropQueueInterface::numberOfItems
MemoryQueue::claimItem public function Claim an item in the queue for processing. Overrides BackdropQueueInterface::claimItem
MemoryQueue::deleteItem public function Delete a finished item from the queue. Overrides BackdropQueueInterface::deleteItem
MemoryQueue::releaseItem public function Release an item that the worker could not process, so another worker can come in and process it before the timeout expires. Overrides BackdropQueueInterface::releaseItem
MemoryQueue::createQueue public function Create a queue. Overrides BackdropQueueInterface::createQueue
MemoryQueue::deleteQueue public function Delete a queue and every item in the queue. Overrides BackdropQueueInterface::deleteQueue