from threading import Thread
+import util
+
from errors import *
class Queue(Thread):
def run(self):
self.log.debug("Started event queue")
+ util.setprocname("queue")
+
while self.__running or self.__queue:
if not self.__queue:
#self.log.debug("Queue sleeping for %s seconds" % self.heartbeat)