publisher = $publisher; } /** * Adding data to queue * * @param $data * @return void */ public function publishData($data) { $this->publisher->publish(self::TOPIC_NAME, $data); } }