Hook up the send queue and create a federation sender worker

This commit is contained in:
Erik Johnston 2016-11-16 17:34:44 +00:00
parent 1587b5a033
commit ed787cf09e
8 changed files with 418 additions and 21 deletions

View file

@ -25,6 +25,9 @@ class TransactionStore(BaseSlavedStore):
].orig
_get_destination_retry_timings = DataStore._get_destination_retry_timings.__func__
def prep_send_transaction(self, transaction_id, destination, origin_server_ts):
return []
# For now, don't record the destination rety timings
def set_destination_retry_timings(*args, **kwargs):
return defer.succeed(None)