From a881e3a23cc9eae806f528f41aef9402c5b5b630 Mon Sep 17 00:00:00 2001
From: t123yh <t123yh@outlook.com>
Date: Fri, 25 Aug 2017 21:07:18 +0800
Subject: [PATCH] Fix priority.

---
 src/daemon/rmq.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/daemon/rmq.ts b/src/daemon/rmq.ts
index dd09427..ac7913a 100644
--- a/src/daemon/rmq.ts
+++ b/src/daemon/rmq.ts
@@ -82,7 +82,7 @@ export async function runTask(task: RPCRequest, priority: number, started?: () =
     winston.debug(`Task ${correlationId} callback queue subscribed.`);
 
     channel.sendToQueue(rmqCommon.taskQueueName, msgpack.encode(task), {
-        correlationId: correlationId, replyTo: callbackQueue
+        correlationId: correlationId, replyTo: callbackQueue, priority: priority
     });
     winston.debug(`Task ${correlationId} sent.`);