jobParams = array($subtaskId, $eventNames, $values); return $this; } /** * Execute job * * @param int $subtaskId * @param array $eventNames * @param array $values */ public function execute($subtaskId, array $eventNames, array $values = array()) { $event = SubtaskEventBuilder::getInstance($this->container) ->withSubtaskId($subtaskId) ->withValues($values) ->buildEvent(); if ($event !== null) { foreach ($eventNames as $eventName) { $this->dispatcher->dispatch($event, $eventName); } } } }