def enqueue_data(self, event_type, data):
with self.lock:<EOL><INDENT>listeners = self.listeners.values()<EOL>for listener in listeners:<EOL><INDENT>listener.enqueue(event_type, data)<EOL>self.must_process = True<EOL><DEDENT><DEDENT>
Enqueue a data item for specific event type