Commit 953eb382 by 李福中

Make push timeout adjustable

parent ddb1aa07
...@@ -33,10 +33,15 @@ class PushsController < ApplicationController ...@@ -33,10 +33,15 @@ class PushsController < ApplicationController
token = token_and_options(request).first token = token_and_options(request).first
if token == Token.token(params[:app_name]) if token == Token.token(params[:app_name])
if params.has_key?(:sync_push) if params.has_key?(:sync_push)
Timeout.timeout(3) { timeout_seconds = $redis.get('push_timeout').to_i
if timeout_seconds > 0
Timeout.timeout(timeout_seconds) {
::PushWorker.new.perform(device_ids_opts, message, igetui_opts, params[:app_type]) ::PushWorker.new.perform(device_ids_opts, message, igetui_opts, params[:app_type])
} }
else else
::PushWorker.new.perform(device_ids_opts, message, igetui_opts, params[:app_type])
end
else
::PushWorker.perform_async(device_ids_opts, message, igetui_opts, params[:app_type]) ::PushWorker.perform_async(device_ids_opts, message, igetui_opts, params[:app_type])
end end
render json: { code: 0, message: 'success', describe: '异步任务正在处理'} render json: { code: 0, message: 'success', describe: '异步任务正在处理'}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment