__init__.py 文件源码

def __init__(self, thread_sleep=0.1, parent=None, storeMessages = False):
        self.consumer_lock = threading.Lock()
        threading.Thread.__init__(self)
        self._terminateMe=False
        self._pauseMe=True
        self.state = threading.Condition()
        self.setDaemon(True)
        self.actionQueue = Queue.Queue()
        self.thread_sleep = thread_sleep
        self._messages = {}
        self._allMsg = []
        self._connections = {}
        self.consumers = {}
        self.supplier_admin = self.SupplierAdmin_i(self)
        self._parent_comp = parent
        self._storeMessages = storeMessages
        self._storedMessages = []
        self.startPort()