diff --git a/CloudSync/Config/GetPhieuDonTiepPubSub.json b/CloudSync/Config/GetPhieuDonTiepPubSub.json
index e843ec8..14c9741 100644
--- a/CloudSync/Config/GetPhieuDonTiepPubSub.json
+++ b/CloudSync/Config/GetPhieuDonTiepPubSub.json
@@ -6,5 +6,6 @@
   "CloudGetUrl": "",
   "CloudToken": "",
   "Channel": "lichkham/pending",
-  "Lane": ""
+  "Lane": "",
+  "urlCQSNode": ""
 }
diff --git a/CloudSync/Process/GetKetQuaKCBPubSub.cs b/CloudSync/Process/GetKetQuaKCBPubSub.cs
index 5274bda..476c5fe 100644
--- a/CloudSync/Process/GetKetQuaKCBPubSub.cs
+++ b/CloudSync/Process/GetKetQuaKCBPubSub.cs
@@ -77,12 +77,13 @@ protected override async void Scan()
                 logger.Info("0.1. Pulling ketqua kcb...");
                 var authToken = Config.FindValue("CloudToken");
                 var vLane = Config.GetValue<string>("Lane");
+                 var sNodeCQS = Config.GetValue("urlCQSNode", "");
                 var apiMethodUrl = $"{apiCloudGetUrl}?msgToken={token}";
                 if (vLane.IsNotNullOrEmpty())
                 {
                     apiMethodUrl += $"&lane={vLane}";
                 }
-                var vListResult = await apiMethodUrl.GetAsJson<VMData[]>(authToken);
+                var vListResult = await apiMethodUrl.GetAsJson<VMData[]>(authToken, sNodeCQS);
                 if (vListResult != null)
                 {
                     logger.Info($"1.1. Pulled new result: data={JsonConvert.SerializeObject(vListResult)}");
diff --git a/CloudSync/Process/GetPhieuDonTiepPubSub.cs b/CloudSync/Process/GetPhieuDonTiepPubSub.cs
index f1cb6b1..aa67572 100644
--- a/CloudSync/Process/GetPhieuDonTiepPubSub.cs
+++ b/CloudSync/Process/GetPhieuDonTiepPubSub.cs
@@ -9,7 +9,7 @@
 
 namespace CloudSync.Process
 {
-    public class GetPhieuDonTiepPubSub: QueueJobProcess<object>
+    public class GetPhieuDonTiepPubSub : QueueJobProcess<object>
     {
         private string latestMessageToken = string.Empty;
 
@@ -22,8 +22,9 @@ protected override void PostInitialize()
             // TODO: Cập nhật cấu hình CloudToken vào file cấu hình Config/GetPhieuDonTiepPubSub.json
             var authCloudToken = Config.FindValue("CloudToken");
             var subChannel = Config.GetValue("Channel", "lichkham/pending");
+            var sNodeCQS = Config.GetValue("urlCQSNode", "");
             var infoToken = authCloudToken?.Substring(0, 6) ?? "NULL";
-            if (authCloudToken is null || !PubSubHelper.Initialize(authCloudToken).Wait(10000))
+            if (authCloudToken is null || !PubSubHelper.Initialize(authCloudToken, sNodeCQS).Wait(10000))
             {
                 logger.Error($"Cannot init Pubsub => Please verify CloudToken, token={infoToken}...");
                 return;
@@ -76,12 +77,13 @@ protected override async void Scan()
                 logger.Info("0.1. Pulling ketqua phieu don tiep...");
                 var authToken = Config.FindValue("CloudToken");
                 var vLane = Config.GetValue<string>("Lane");
+                var sNodeCQS = Config.GetValue("urlCQSNode", "");
                 var apiMethodUrl = $"{apiCloudGetUrl}?msgToken={token}";
                 if (vLane.IsNotNullOrEmpty())
                 {
                     apiMethodUrl += $"&lane={vLane}";
                 }
-                var vListResult = await apiMethodUrl.GetAsJson<object>(authToken);
+                var vListResult = await apiMethodUrl.GetAsJson<object>(authToken, sNodeCQS);
                 if (vListResult != null)
                 {
                     logger.Info($"1.1. Pulled new result: data={JsonConvert.SerializeObject(vListResult)}");