|
|
@ -34,6 +34,7 @@ async function newChannel(): Promise<amqp.Channel> { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
export function pushTask(task: any) { |
|
|
|
export function pushTask(task: any) { |
|
|
|
|
|
|
|
winston.info("Got task", task); |
|
|
|
publicChannel.sendToQueue(rmqCommon.judgeQueueName, msgpack.encode(task), { |
|
|
|
publicChannel.sendToQueue(rmqCommon.judgeQueueName, msgpack.encode(task), { |
|
|
|
priority: task.content.priority |
|
|
|
priority: task.content.priority |
|
|
|
}); |
|
|
|
}); |
|
|
|