MessageQueueCreator.php in Open Social 10.1.x
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.3 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.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\activity_creator\Plugin\ActivityActionManager;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
use Drupal\Core\Queue\QueueFactory;
use Drupal\node\Entity\Node;
use Symfony\Component\DependencyInjection\ContainerInterface;
/**
* 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 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);
}
}
}
}
Classes
Name | Description |
---|---|
MessageQueueCreator | A report worker. |