diff options
| author | Brendan Abolivier <babolivier@matrix.org> | 2021-10-26 15:17:36 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-10-26 15:17:36 +0200 |
| commit | c7a5e49664ab0bd18a57336e282fa6c3b9a17ca0 (patch) | |
| tree | eba568a8f118fe8eb9f83b1302ab3104f55a6171 /synapse/replication | |
| parent | Move DNS lookups into separate thread pool (#11177) (diff) | |
| download | synapse-c7a5e49664ab0bd18a57336e282fa6c3b9a17ca0.tar.xz | |
Implement an `on_new_event` callback (#11126)
Co-authored-by: Andrew Morgan <1342360+anoadragon453@users.noreply.github.com>
Diffstat (limited to 'synapse/replication')
| -rw-r--r-- | synapse/replication/tcp/client.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index 961c17762e..e29ae1e375 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -207,11 +207,12 @@ class ReplicationDataHandler: max_token = self.store.get_room_max_token() event_pos = PersistedEventPosition(instance_name, token) - self.notifier.on_new_room_event_args( + await self.notifier.on_new_room_event_args( event_pos=event_pos, max_room_stream_token=max_token, extra_users=extra_users, room_id=row.data.room_id, + event_id=row.data.event_id, event_type=row.data.type, state_key=row.data.state_key, membership=row.data.membership, |