0

使用vsivsi:job-collection,我已经设置了示例中的作业,但不同之处在于我的作业是在服务器上处理的。与在客户端处理作业的示例应用程序相比,我看不出缺少什么。

lib/db.coffee

@ParsingJobs = JobCollection('parsing', {
    workTimeout: 10000
    transform: (d) ->
        try
            res = new Job(ParsingJobs, d)
        catch e
            res = d
        return res
})

if Meteor.isServer
    Meteor.startup(->
        ParsingJobs.allow({
            admin: (user_id, method, params) ->
                # commented temporarily Roles.userIsInRole(Meteor.user(), ['admin'])
                true
        })

        ParsingJobs.startJobServer()

服务器.coffee

que = ParsingJobs.processJobs('parsing', {workTimeout: 10000}, (job, cb) ->
    # do some processing
    job.done('success')
    cb()

ParsingJobs.find({type: 'parsing', status: 'ready'}).observe
    added: ->
        que.trigger()

在客户端上,我可以运行一个 shell 命令:

x = ParsingJobs.find().fetch()[0]
x.rerun()

结果:

job_class.js:16 未捕获错误:作业远程方法调用错误,未找到有效调用方法。

我究竟做错了什么?

4

1 回答 1

1

更改此行:

que = ParsingJobs.processJobs('parsing', {workTimeout: 10000}, (job, cb) ->

对此:

que = Job.processJobs('parsing', {workTimeout: 10000}, (job, cb) ->
于 2016-11-22T20:56:29.853 回答