diff options
| author | Erik Johnston <erik@matrix.org> | 2014-08-27 15:33:52 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2014-08-27 15:33:52 +0100 |
| commit | bfe9faad5abf429b7023aaaeb3ba3200a75bf485 (patch) | |
| tree | 42e4db7e5cb31fa888294c619badec80e3a73cb9 /synapse/notifier.py | |
| parent | Convert get_paginat_rows to use PaginationConfig. This allows people to suppl... (diff) | |
| download | synapse-bfe9faad5abf429b7023aaaeb3ba3200a75bf485.tar.xz | |
Index sources in a nicer fashion.
Diffstat (limited to 'synapse/notifier.py')
| -rw-r--r-- | synapse/notifier.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index a69d5343cb..b969011b32 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -69,7 +69,7 @@ class Notifier(object): def on_new_room_event(self, event, extra_users=[]): room_id = event.room_id - source = self.event_sources.sources[0] + source = self.event_sources.sources["room"] listeners = self.rooms_to_listeners.get(room_id, set()).copy() @@ -94,7 +94,7 @@ class Notifier(object): @defer.inlineCallbacks def on_new_user_event(self, users=[], rooms=[]): - source = self.event_sources.sources[1] + source = self.event_sources.sources["presence"] listeners = set() @@ -176,7 +176,7 @@ class Notifier(object): limit = listener.limit # TODO (erikj): DeferredList? - for source in self.event_sources.sources: + for source in self.event_sources.sources.values(): stuff, new_token = yield source.get_new_events_for_user( listener.user, from_token, |