diff --git a/transfer_service/task_executor.py b/transfer_service/task_executor.py
index 9715af2b260f0af67272dd2b631c2b385ea50212..a937e23094f1eb3c0030fdad344fce8fae99a3fc 100644
--- a/transfer_service/task_executor.py
+++ b/transfer_service/task_executor.py
@@ -6,7 +6,7 @@ from config import Config
 from job_queue import JobQueue
 
 
-class Preprocessor(Process):
+class TaskExecutor(Process):
 
     def __init__(self):
         config = Config("vos_ts.conf")
@@ -14,16 +14,22 @@ class Preprocessor(Process):
         self.maxPendingJobs = self.params.getint("max_pending_jobs")
         self.maxReadyJobs = self.params.getint("max_ready_jobs")
         self.execWaitTime = self.params.getint("exec_wait_time")
-        self.pendingQueue = JobQueue("pending")
-        self.readyQueue = JobQueue("ready")
-        super(Preprocessor, self).__init__()
-        
+        self.srcQueue = None
+        self.destQueue = None
+        super(TaskExecutor, self).__init__()
+
     def wait(self):
         time.sleep(self.execWaitTime)
 
+    def setSourceQueueName(self, srcQueueName):
+        self.srcQueue = JobQueue(srcQueueName)
+
+    def setDestinationQueueName(self, destQueueName):
+        self.destQueue = JobQueue(destQueueName)
+
     def run(self):
         """
         This method must be implemented by
         inherited classes
         """
-        pass
\ No newline at end of file
+        pass