jobParams = array($commentId, $eventName); return $this; } /** * Execute job * * @param int $commentId * @param string $eventName */ public function execute($commentId, $eventName) { $event = CommentEventBuilder::getInstance($this->container) ->withCommentId($commentId) ->buildEvent(); if ($event !== null) { $this->dispatcher->dispatch($eventName, $event); if ($eventName === CommentModel::EVENT_CREATE) { $userMentionJob = $this->userMentionJob->withParams($event['comment']['comment'], CommentModel::EVENT_USER_MENTION, $event); $this->queueManager->push($userMentionJob); } } } }