.

onlyone/__main__.py

@@ -30,7 +30,7 @@ if args.configFile:
        log.info("config file content : " +  configTxt)
        log.info("trying read yaml")
        configDict = yaml.safe_load(configTxt)
-       #manager.load(configDict, True)
+       manager.load(configDict, True)
    else:
        log.error("Current Path:" + os.getcwd())
        log.error("File dont exists:" + args.configfile)

onlyone/namedpipes/__init__.py

@@ -18,7 +18,7 @@ class Server:
             if oe.errno != errno.EEXIST:
                 raise
         
-        readTask = ReadTask()        
+        readTask = ReadTask(self)        
         self.__readThread = threading.Thread(target=readTask.run, args = (fifoname,) )
         self.__readThread.start()
 
@@ -26,8 +26,9 @@ class Server:
         self.__readThread.kill()
 
 class ReadTask:
-    def __init__(self):
+    def __init__(self, server):
         self.__kill=False
+        self.server=server
 
     def kill(self):
         self.__kill=True
@@ -42,8 +43,10 @@ class ReadTask:
                     log.info("FIFO closed")
                     break
                 log.info('FIFO Data: "{0}"'.format(data))
+                self.server.manager.current(format(data).strip())
 
-    def run(self, fifoname):
+    def run(self, fifoname, manager):
+        self.mana
         while True:
             if self.__kill:
                 return