|
@@ -59,6 +59,7 @@ class NewUserPushMsgDelay implements ShouldQueue
|
|
|
foreach ($tasks as $task) {
|
|
|
$job = new NewUserPushMsg($this->uid, $task);
|
|
|
dispatch($job)->onConnection('rabbitmq')->onQueue('new_user_push_msg')->delay($task->time_delay);
|
|
|
+ myLog('new_user_push_msg')->info("task_id:{$task->id}; uid: {$this->uid}");
|
|
|
}
|
|
|
}
|
|
|
}
|