from threading import Thread
+from database import Database
from errors import *
class Queue(Thread):
self.__running = True
self.__queue = []
+ self.db = Database(log)
+
def __len__(self):
return self.length
def run(self):
self.log.debug("Started event queue")
+ self.db.open()
+
while self.__running or self.__queue:
if not self.__queue:
#self.log.debug("Queue sleeping for %s seconds" % self.heartbeat)
except EventException, e:
self.log.error("Catched event exception: %s" % e)
+ self.db.close()
+
def shutdown(self):
self.__running = False
self.log.debug("Shutting down queue")