1 files changed, 9 insertions, 6 deletions
diff --git a/synapse/server.py b/synapse/server.py
index 894e9c2acf..cd0c1a51be 100644
--- a/synapse/server.py
+++ b/synapse/server.py
@@ -47,7 +47,8 @@ from synapse.handlers.device import DeviceHandler
from synapse.handlers.e2e_keys import E2eKeysHandler
from synapse.handlers.presence import PresenceHandler
from synapse.handlers.room_list import RoomListHandler
-from synapse.handlers.room_member import RoomMemberHandler
+from synapse.handlers.room_member import RoomMemberMasterHandler
+from synapse.handlers.room_member_worker import RoomMemberWorkerHandler
from synapse.handlers.set_password import SetPasswordHandler
from synapse.handlers.sync import SyncHandler
from synapse.handlers.typing import TypingHandler
@@ -101,8 +102,8 @@ class HomeServer(object):
DEPENDENCIES = [
'http_client',
'db_pool',
- 'replication_client',
- 'replication_server',
+ 'federation_client',
+ 'federation_server',
'handlers',
'v1auth',
'auth',
@@ -199,10 +200,10 @@ class HomeServer(object):
def get_ratelimiter(self):
return self.ratelimiter
- def build_replication_client(self):
+ def build_federation_client(self):
return FederationClient(self)
- def build_replication_server(self):
+ def build_federation_server(self):
return FederationServer(self)
def build_handlers(self):
@@ -392,7 +393,9 @@ class HomeServer(object):
return SpamChecker(self)
def build_room_member_handler(self):
- return RoomMemberHandler(self)
+ if self.config.worker_app:
+ return RoomMemberWorkerHandler(self)
+ return RoomMemberMasterHandler(self)
def build_federation_registry(self):
return FederationHandlerRegistry()
|