diff options
| author | Erik Johnston <erik@matrix.org> | 2016-11-16 17:34:44 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-11-16 17:34:44 +0000 |
| commit | ed787cf09edd77e39ad9da0b957359214de85287 (patch) | |
| tree | befff8fe0284099e1e2df9eccd729ff1eedd4727 /synapse/replication/slave/storage/deviceinbox.py | |
| parent | Add initial cut of federation send queue (diff) | |
| download | synapse-ed787cf09edd77e39ad9da0b957359214de85287.tar.xz | |
Hook up the send queue and create a federation sender worker
Diffstat (limited to 'synapse/replication/slave/storage/deviceinbox.py')
| -rw-r--r-- | synapse/replication/slave/storage/deviceinbox.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/deviceinbox.py b/synapse/replication/slave/storage/deviceinbox.py index 3bfd5e8213..373212d42d 100644 --- a/synapse/replication/slave/storage/deviceinbox.py +++ b/synapse/replication/slave/storage/deviceinbox.py @@ -29,9 +29,14 @@ class SlavedDeviceInboxStore(BaseSlavedStore): "DeviceInboxStreamChangeCache", self._device_inbox_id_gen.get_current_token() ) + self._device_federation_outbox_stream_cache = StreamChangeCache( + "DeviceFederationOutboxStreamChangeCache", + self._device_inbox_id_gen.get_current_token() + ) get_to_device_stream_token = DataStore.get_to_device_stream_token.__func__ get_new_messages_for_device = DataStore.get_new_messages_for_device.__func__ + get_new_device_msgs_for_remote = DataStore.get_new_device_msgs_for_remote.__func__ delete_messages_for_device = DataStore.delete_messages_for_device.__func__ def stream_positions(self): |