Commit 999fe2fa authored by Aurel's avatar Aurel

add registered method


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@190 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 94587836
......@@ -39,6 +39,13 @@ class Dispatcher(Thread):
key = (conn.getUUID(), msg_id)
self.message_table[key] = queue
def registered(self, uuid):
"""Check if a connection is registered into message table."""
for conn_uuid, msg_id in self.message_table.keys():
if uuid == conn_uuid:
return True
return False
def connectToPrimaryMasterNode(self, app):
"""Connect to a primary master node.
This can be called either at bootstrap or when
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment