如题，在调用
Resque.enqueue(PushMessageWorker, self.id, "activity", 'C')
总是提示
The error occurred while evaluating nil.[]
... ...
plugins/resque/lib/resque.rb:210:in `queue'
resque 的源码是
def queue(name)
@queues[name.to_s]
end
有朋友知道问题出在哪么？
补充 PushMessageWorker 的代码
class PushMessageWorker
@queue = :push_message_que
#活动的id号
def self.perform(obj_id,type,action)
#... ...
end
end
由两个问题引起：
- redis-namespace 的版本太高，应该使用 1.0.3
- 不需要安装 resque 的 plugin
# -*- encoding: utf-8 -*-
module ResqueJobs
class ResqueJob
end
class SyncUser < ResqueJob
@queue = :base
def self.perform(user_id)
puts "=================开始同步#{user_id}店铺信息=================="
User.find(user_id).subusers_sync # 店铺子账户
User.find(user_id).rates_sync # 店铺评价
User.find(user_id).addresses_sync # 仓储地址
User.find(user_id).chatpeers_sync # 旺旺接待
User.find(user_id).wangwangs_sync # 记录旺旺统计
User.find(user_id).members_sync # 卖家的会员
puts "=================结束同步#{user_id}店铺信息=================="
end
end
end
我用 resque-scheduler，会有些不一样：
User.all.each do |user|
Resque.set_schedule("base-#{user.user_id}", { cron: '0 9 * * *', queue: :base, class: 'ResqueJobs::SyncUser', args: user.id })
end
