diff --git a/transfer_service/abort_job_rpc_server.py b/transfer_service/abort_job_rpc_server.py
index ec0cb9c0375370c8731cf2b1e8f977166471f5fb..df508f858dd7d382defa4a8186e6cd7824c52b31 100644
--- a/transfer_service/abort_job_rpc_server.py
+++ b/transfer_service/abort_job_rpc_server.py
@@ -16,8 +16,8 @@ class AbortJobRPCServer(RedisRPCServer):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"],
-                                  4,
-                                  8)
+                                  1,
+                                  2)
         super(AbortJobRPCServer, self).__init__(host, port, db, rpcQueue)
 
     def callback(self, requestBody):
diff --git a/transfer_service/data_rpc_server.py b/transfer_service/data_rpc_server.py
index 695cc86914895e9d14e35ca304225686224c5a28..f9c80fc0462e4f0c5bb4d99917bdc0f44d329a41 100644
--- a/transfer_service/data_rpc_server.py
+++ b/transfer_service/data_rpc_server.py
@@ -30,8 +30,8 @@ class DataRPCServer(RedisRPCServer):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"],
-                                  4,
-                                  8)
+                                  1,
+                                  2)
         self.params = config.loadSection("transfer_node")
         self.storageStorePath = self.params["store_path"]
         self.params = config.loadSection("scheduling")
diff --git a/transfer_service/get_job_rpc_server.py b/transfer_service/get_job_rpc_server.py
index 8bafbecd347931efb3ebbd0311f0008b52139888..7d06e6de7b792b84a5a7ac0d0a4f04779455e4f1 100644
--- a/transfer_service/get_job_rpc_server.py
+++ b/transfer_service/get_job_rpc_server.py
@@ -18,8 +18,8 @@ class GetJobRPCServer(RedisRPCServer):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"],
-                                  4,
-                                  8)
+                                  1,
+                                  2)
         super(GetJobRPCServer, self).__init__(host, port, db, rpcQueue)
 
     def callback(self, requestBody):
diff --git a/transfer_service/import_rpc_server.py b/transfer_service/import_rpc_server.py
index 99cdef8d441366b362a38f12498676fceeddd74a..faadbc8474cae9219de774666fbccdf42350a96a 100644
--- a/transfer_service/import_rpc_server.py
+++ b/transfer_service/import_rpc_server.py
@@ -22,7 +22,7 @@ class ImportRPCServer(RedisRPCServer):
                                   self.params.getint("port"),
                                   self.params["db"],
                                   1,
-                                  1)
+                                  2)
         self.params = config.loadSection("scheduling")
         self.maxReadyJobs = self.params.getint("max_ready_jobs")
         self.importReadyQueue = JobQueue("import_ready")
diff --git a/transfer_service/job_rpc_server.py b/transfer_service/job_rpc_server.py
index d1a1be95808f7fa3bc66be212ee1a527da02bbad..d986060d4377ec13d3ea723735fec1ff0537aa8b 100644
--- a/transfer_service/job_rpc_server.py
+++ b/transfer_service/job_rpc_server.py
@@ -18,8 +18,8 @@ class JobRPCServer(RedisRPCServer):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"],
-                                  4,
-                                  8)
+                                  1,
+                                  2)
         super(JobRPCServer, self).__init__(host, port, db, rpcQueue)
 
     def callback(self, requestBody):
diff --git a/transfer_service/start_job_rpc_server.py b/transfer_service/start_job_rpc_server.py
index 2ca989538915ad3815991a45ea50c48ac5c49696..097933510891790b663d0324207d1cc21be958f9 100644
--- a/transfer_service/start_job_rpc_server.py
+++ b/transfer_service/start_job_rpc_server.py
@@ -20,8 +20,8 @@ class StartJobRPCServer(RedisRPCServer):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"],
-                                  4,
-                                  8)
+                                  1,
+                                  2)
         self.params = config.loadSection("scheduling")
         self.maxPendingJobs = self.params.getint("max_pending_jobs")
         self.maxTerminatedJobs = self.params.getint("max_terminated_jobs")
diff --git a/transfer_service/storage_rpc_server.py b/transfer_service/storage_rpc_server.py
index dcf1505d893cccc0adecec718d51cff18ea6d1e9..b09c9c87760778700a948de898898885b40ce15f 100644
--- a/transfer_service/storage_rpc_server.py
+++ b/transfer_service/storage_rpc_server.py
@@ -18,8 +18,8 @@ class StorageRPCServer(RedisRPCServer):
                                   self.params["host"],
                                   self.params.getint("port"),
                                   self.params["db"],
-                                  4,
-                                  8)
+                                  1,
+                                  2)
         super(StorageRPCServer, self).__init__(host, port, db, rpcQueue)
 
     def callback(self, requestBody):