public static function DrupalQueue::get
7.x system.queue.inc | public static DrupalQueue::get($name, $reliable = FALSE) |
Returns the queue object for a given name.
The following variables can be set by variable_set or $conf overrides:
- queue_class_$name: the class to be used for the queue $name.
- queue_default_class: the class to use when queue_class_$name is not defined. Defaults to SystemQueue, a reliable backend using SQL.
- queue_default_reliable_class: the class to use when queue_class_$name is not defined and the queue_default_class is not reliable. Defaults to SystemQueue.
Parameters
$name: Arbitrary string. The name of the queue to work with.
$reliable: TRUE if the ordering of items and guaranteeing every item executes at least once is important, FALSE if scalability is the main concern.
Return value
The queue object for a given name.
11 calls to DrupalQueue::get()
- aggregator_cron in drupal-7.x/
modules/ aggregator/ aggregator.module - Implements hook_cron().
- drupal_cron_run in drupal-7.x/
includes/ common.inc - Executes a cron run when called.
- hook_cron in drupal-7.x/
modules/ system/ system.api.php - Perform periodic actions.
- QueueTestCase::testQueue in drupal-7.x/
modules/ system/ system.test - Queues and dequeues a set of items to check the basic queue functionality.
- UpdateCoreTestCase::testFetchTasks in drupal-7.x/
modules/ update/ update.test - Tests that exactly one fetch task per project is created and not more.
File
- drupal-7.x/
modules/ system/ system.queue.inc, line 81 - Queue functionality.
Class
- DrupalQueue
- Factory class for interacting with queues.
Code
public static function get($name, $reliable = FALSE) {
static $queues;
if (!isset($queues[$name])) {
$class = variable_get('queue_class_' . $name, NULL);
if (!$class) {
$class = variable_get('queue_default_class', 'SystemQueue');
}
$object = new $class($name);
if ($reliable && !$object instanceof DrupalReliableQueueInterface) {
$class = variable_get('queue_default_reliable_class', 'SystemQueue');
$object = new $class($name);
}
$queues[$name] = $object;
}
return $queues[$name];
}