DeployProcessorQueue.inc in Deploy - Content Staging 7.2
Same filename and directory in other branches
Queue API plugin for deploy Processor.
File
plugins/DeployProcessorQueue.incView source
<?php
/**
* @file
* Queue API plugin for deploy Processor.
*/
/**
* Processor class using the Queue API
*/
class DeployProcessorQueue extends DeployProcessorMemory {
/**
* {@inheritdoc}
*/
public function deploy($deployment_key, DeployEndpoint $endpoint, $lock_name = NULL) {
deploy_log($deployment_key, DEPLOY_STATUS_PROCESSING);
$queue = DrupalQueue::get('deploy_deploy');
foreach ($this->aggregator as $entity) {
// We don't want entities that has a cause, i.e. not dependencies, because
// those'll be taken care of when the service iterates over the queue.
if (empty($entity->__metadata['cause'])) {
$entity_info = entity_get_info($entity->__metadata['type']);
$id_key = $entity_info['entity keys']['id'];
$entity->__metadata['id'] = $entity->{$id_key};
$entity->__metadata['deployment_key'] = $deployment_key;
$entity->__metadata['plan_name'] = $this->aggregator->plan->name;
$entity->__metadata['endpoint_name'] = $endpoint->name;
$entity->__metadata['lock_name'] = $lock_name;
$queue
->createItem($entity);
}
}
}
/**
* {@inheritdoc}
*/
public function publish($deployment_key, DeployEndpoint $endpoint, $lock_name = NULL) {
$queue = DrupalQueue::get('deploy_publish');
foreach ($this->aggregator as $entity) {
// We don't want entities that has a cause, i.e. not dependencies, because
// those'll be taken care of when the service iterates over the queue.
if (empty($entity->__metadata['cause'])) {
$entity_info = entity_get_info($entity->__metadata['type']);
$id_key = $entity_info['entity keys']['id'];
$entity->__metadata['id'] = $entity->{$id_key};
$entity->__metadata['deployment_key'] = $deployment_key;
$entity->__metadata['plan_name'] = $this->aggregator->plan->name;
$entity->__metadata['endpoint_name'] = $endpoint->name;
$entity->__metadata['lock_name'] = $lock_name;
$queue
->createItem($entity);
}
}
}
}
Classes
Name | Description |
---|---|
DeployProcessorQueue | Processor class using the Queue API |