MessageQueueCreator.php in Open Social 8.3
Same filename and directory in other branches
- 8.9 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8.2 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8.4 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8.5 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8.6 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8.7 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 8.8 modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 10.3.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 10.0.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 10.1.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
- 10.2.x modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.php
File
modules/custom/activity_logger/src/Plugin/QueueWorker/MessageQueueCreator.phpView source
<?php
namespace Drupal\activity_logger\Plugin\QueueWorker;
use Drupal\node\Entity\Node;
/**
* 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
*/
class MessageQueueCreator extends MessageQueueBase {
/**
* {@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);
$queue = \Drupal::queue('activity_logger_message');
$queue
->createItem($data);
}
else {
$activity_logger_factory = \Drupal::service('plugin.manager.activity_action.processor');
// Trigger the create action for enttites.
$create_action = $activity_logger_factory
->createInstance('create_entitiy_action');
$create_action
->createMessage($entity);
}
}
}
}
Classes
Name | Description |
---|---|
MessageQueueCreator | A report worker. |