class MessageQueueCreator in Open Social 10.3.x
Same name and namespace in other branches
- 8.9 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.2 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.3 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.4 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.5 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.6 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.7 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 8.8 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 10.0.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 10.1.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
- 10.2.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator
A report worker.
@QueueWorker( id = "activity_logger_message", title = @Translation("Process activity_logger_message queue."), cron = {"time" = 60} )
This QueueWorker is responsible for creating message items from the queue
Hierarchy
- class \Drupal\Component\Plugin\PluginBase implements DerivativeInspectionInterface, PluginInspectionInterface
- class \Drupal\Core\Queue\QueueWorkerBase implements QueueWorkerInterface
- class \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueBase
- class \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueCreator implements ContainerFactoryPluginInterface
- class \Drupal\activity_logger\Plugin\QueueWorker\MessageQueueBase
- class \Drupal\Core\Queue\QueueWorkerBase implements QueueWorkerInterface
Expanded class hierarchy of MessageQueueCreator
File
- modules/
custom/ activity_logger/ src/ Plugin/ QueueWorker/ MessageQueueCreator.php, line 22
Namespace
Drupal\activity_logger\Plugin\QueueWorkerView source
class MessageQueueCreator extends MessageQueueBase implements ContainerFactoryPluginInterface {
/**
* The action manager.
*
* @var \Drupal\activity_creator\Plugin\ActivityActionManager
*/
protected $actionManager;
/**
* MessageQueueCreator constructor.
*
* @param array $configuration
* The configuration.
* @param string $plugin_id
* The plugin id.
* @param array $plugin_definition
* The plugin definition.
* @param \Drupal\Core\Queue\QueueFactory $queue
* The queue.
* @param \Drupal\activity_creator\Plugin\ActivityActionManager $actionManager
* The action manager.
*/
public function __construct(array $configuration, $plugin_id, array $plugin_definition, QueueFactory $queue, ActivityActionManager $actionManager) {
parent::__construct($configuration, $plugin_id, $plugin_definition, $queue);
$this->actionManager = $actionManager;
}
/**
* {@inheritdoc}
*/
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
return new static($configuration, $plugin_id, $plugin_definition, $container
->get('queue'), $container
->get('plugin.manager.activity_action.processor'));
}
/**
* {@inheritdoc}
*/
public function processItem($data) {
// First make sure it's an actual entity.
if ($entity = Node::load($data['entity_id'])) {
// Check if it's created more than 20 seconds ago.
$timestamp = $entity
->getCreatedTime();
// Current time.
$now = time();
$diff = abs($now - $timestamp);
// Items must be at least 5 seconds old.
if ($diff <= 5 && $now > $timestamp) {
// Wait for 100 milliseconds.
// We don't want to flood the DB with unprocessable queue items.
usleep(100000);
$this
->createQueueItem('activity_logger_message', $data);
}
else {
// Trigger the create action for enttites.
$create_action = $this->actionManager
->createInstance('create_entitiy_action');
$create_action
->createMessage($entity);
}
}
}
}
Members
Name![]() |
Modifiers | Type | Description | Overrides |
---|---|---|---|---|
MessageQueueBase:: |
protected | property | The queue. | |
MessageQueueBase:: |
protected | function | Simple reporter log and display information about the queue. | |
MessageQueueCreator:: |
protected | property | The action manager. | |
MessageQueueCreator:: |
public static | function |
Creates an instance of the plugin. Overrides ContainerFactoryPluginInterface:: |
|
MessageQueueCreator:: |
public | function |
Works on a single queue item. Overrides QueueWorkerInterface:: |
|
MessageQueueCreator:: |
public | function |
MessageQueueCreator constructor. Overrides MessageQueueBase:: |
|
PluginBase:: |
protected | property | Configuration information passed into the plugin. | 1 |
PluginBase:: |
protected | property | The plugin implementation definition. | 1 |
PluginBase:: |
protected | property | The plugin_id. | |
PluginBase:: |
constant | A string which is used to separate base plugin IDs from the derivative ID. | ||
PluginBase:: |
public | function |
Gets the base_plugin_id of the plugin instance. Overrides DerivativeInspectionInterface:: |
|
PluginBase:: |
public | function |
Gets the derivative_id of the plugin instance. Overrides DerivativeInspectionInterface:: |
|
PluginBase:: |
public | function |
Gets the definition of the plugin implementation. Overrides PluginInspectionInterface:: |
2 |
PluginBase:: |
public | function |
Gets the plugin_id of the plugin instance. Overrides PluginInspectionInterface:: |
|
PluginBase:: |
public | function | Determines if the plugin is configurable. |