Commit a6b4e81

committed

move project worker to different queue

1 parent 0204e60 commit a6b4e81Copy full SHA for a6b4e81

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 2 deletions

Original file line number	Diff line number	Diff line change
@@ -82,10 +82,11 @@ amqp.connect(`amqp://${config.AMQP.USER}:${config.AMQP.PASS}@${config.AMQP.HOST}
`82`	`82`	`/**`
`83`	`83`	`* Put a new job on the queue`
`84`	`84`	`* @param {JudgeJob} job`
	`85`	`+ * @param {string} queueName`
`85`	`86`	`* @returns {boolean} true if job was put on queue successfully`
`86`	`87`	`*/`
`87`		`-function queueJob(job: JudgeJob) {`
`88`		`- return jobChannel.sendToQueue(jobQ, Buffer.from(JSON.stringify(job)), { persistent: true })`
	`88`	`+function queueJob(job: JudgeJob,queueName: string=null) {`
	`89`	`+ return jobChannel.sendToQueue(queueName\|\|jobQ, Buffer.from(JSON.stringify(job)), { persistent: true })`
`89`	`90`	`}`
`90`	`91`	`export {`
`91`	`92`	`queueJob,`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,7 @@ export default {`
`35`	`35`	`config: req.body.config,`
`36`	`36`	`timelimit: req.body.timelimit,`
`37`	`37`	`scenario: 'project'`
`38`		`- })`
	`38`	`+ },'project_queue')`
`39`	`39`
`40`	`40`
`41`	`41`	`if (['callback', 'poll'].includes(mode)) {`

Comments

(0)