remove repeat self.messageHandler and set daemon for each process

Change-Id: I2b50a303b071933417e949b1b07140c0a96e89b2

diff --git a/tools/worker.py b/tools/worker.py
index 14f36cd..a816b14 100755 (executable)
--- a/tools/worker.py
+++ b/tools/worker.py
@@ -60,7 +60,6 @@ class Consumer(Process):
                        print "thread %d start %s package " % (self.threadId, packageName)
                        gbsbuild = GbsBuild(packageName,self.threadId)
                        print "thread %d building %s package" % (self.threadId, packageName)
-                       self.messageHandler = KafkaProducer(bootstrap_servers="109.123.100.137:9092")
                        if gbsbuild.build() == "Success":
                        #if True:
                                result = self.messageHandler.send("tizen-unified-status", value = "succeed", key = packageName, partition=0)
@@ -83,6 +82,10 @@ class WorkerPool(object):
                self.producer = Producer()
                self.consumers = [Consumer(i) for i in xrange(WorkerPool.capcaticy)]
        def start(self):
+               #set daemon
+               self.producer.daemon = True
+               for i in range(0, WorkerPool.capcaticy):
+                       self.consumers[i].daemon = True
                print "start Worker pool"
                self.producer.start()
                for i in range(0, WorkerPool.capcaticy):