diff options
| author | Mark Haines <mjark@negativecurvature.net> | 2016-09-08 14:26:47 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-09-08 14:26:47 +0100 |
| commit | 2117c409a01231de146eb38330e3941ea2564e4a (patch) | |
| tree | 806152a98d66013b94882c85cb1cb6129be62e78 /synapse/federation/federation_client.py | |
| parent | Log delta files we're applying (diff) | |
| parent | Merge branch 'develop' into markjh/direct_to_device_federation (diff) | |
| download | synapse-2117c409a01231de146eb38330e3941ea2564e4a.tar.xz | |
Merge pull request #1074 from matrix-org/markjh/direct_to_device_federation
Send device messages over federation
Diffstat (limited to 'synapse/federation/federation_client.py')
| -rw-r--r-- | synapse/federation/federation_client.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/federation/federation_client.py b/synapse/federation/federation_client.py index 627acc6a4f..78719eed25 100644 --- a/synapse/federation/federation_client.py +++ b/synapse/federation/federation_client.py @@ -138,6 +138,12 @@ class FederationClient(FederationBase): return defer.succeed(None) @log_function + def send_device_messages(self, destination): + """Sends the device messages in the local database to the remote + destination""" + self._transaction_queue.enqueue_device_messages(destination) + + @log_function def send_failure(self, failure, destination): self._transaction_queue.enqueue_failure(failure, destination) return defer.succeed(None) |