diff options
author | Mark Haines <mjark@negativecurvature.net> | 2016-05-31 14:31:19 +0100 |
---|---|---|
committer | Mark Haines <mjark@negativecurvature.net> | 2016-05-31 14:31:19 +0100 |
commit | 014e0799f90b67e29fa7d1fcb7938e0a0c6b8617 (patch) | |
tree | e72ab5618420cd31c55493ed56f3e781c6eb1078 /synapse/appservice | |
parent | Merge pull request #802 from matrix-org/dbkr/split_room_list_handler (diff) | |
parent | Move the AS handler out of the Handlers object. (diff) | |
download | synapse-014e0799f90b67e29fa7d1fcb7938e0a0c6b8617.tar.xz |
Merge pull request #803 from matrix-org/markjh/liberate_appservice_handler
Move the AS handler out of the Handlers object.
Diffstat (limited to 'synapse/appservice')
-rw-r--r-- | synapse/appservice/scheduler.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/synapse/appservice/scheduler.py b/synapse/appservice/scheduler.py index 47a4e9f864..9afc8fd754 100644 --- a/synapse/appservice/scheduler.py +++ b/synapse/appservice/scheduler.py @@ -56,22 +56,22 @@ import logging logger = logging.getLogger(__name__) -class AppServiceScheduler(object): +class ApplicationServiceScheduler(object): """ Public facing API for this module. Does the required DI to tie the components together. This also serves as the "event_pool", which in this case is a simple array. """ - def __init__(self, clock, store, as_api): - self.clock = clock - self.store = store - self.as_api = as_api + def __init__(self, hs): + self.clock = hs.get_clock() + self.store = hs.get_datastore() + self.as_api = hs.get_application_service_api() def create_recoverer(service, callback): - return _Recoverer(clock, store, as_api, service, callback) + return _Recoverer(self.clock, self.store, self.as_api, service, callback) self.txn_ctrl = _TransactionController( - clock, store, as_api, create_recoverer + self.clock, self.store, self.as_api, create_recoverer ) self.queuer = _ServiceQueuer(self.txn_ctrl) |