Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2025-05-06 21:55:00 -04:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #4855 from matrix-org/rav/refactor_transaction_queue

Browse source 
Split TransactionQueue up
This commit is contained in:
Richard van der Hoff 2019-03-15 12:32:11 +00:00 • committed by GitHub
commit 3b7ceb2c69
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
8 changed files with 865 additions and 761 deletions
Download patch file Download diff file Expand all files Collapse all files

4
synapse/server.py
View file

@ -42,7 +42,7 @@ from synapse.federation.federation_server import (
ReplicationFederationHandlerRegistry,
)
from synapse.federation.send_queue import FederationRemoteSendQueue
from synapse.federation.transaction_queue import TransactionQueue
from synapse.federation.sender import FederationSender
from synapse.federation.transport.client import TransportLayerClient
from synapse.groups.attestations import GroupAttestationSigning, GroupAttestionRenewer
from synapse.groups.groups_server import GroupsServerHandler
@ -434,7 +434,7 @@ class HomeServer(object):
def build_federation_sender(self):
if self.should_send_federation():
return TransactionQueue(self)
return FederationSender(self)
elif not self.config.worker_app:
return FederationRemoteSendQueue(self)
else: