diff --git a/app/service/CreationTaskService.php b/app/service/CreationTaskService.php
index 10f8283..f9d1950 100644
--- a/app/service/CreationTaskService.php
+++ b/app/service/CreationTaskService.php
@@ -69,6 +69,8 @@ class CreationTaskService extends BaseService
         try {
             $this->dao->update(['id' => $params['id']], $params);
             Db::commit();
+            //投递消息
+            Redis::send('creation-task', ['task_id' => $params['id']]);
         } catch (\Exception $exception) {
             Db::rollback();
             throw new ApiException($exception->getMessage());