1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/app/federation_sender.py b/synapse/app/federation_sender.py
index dcdbe79a17..80ea4c8062 100644
--- a/synapse/app/federation_sender.py
+++ b/synapse/app/federation_sender.py
@@ -237,6 +237,9 @@ class FederationSenderHandler(object):
stream_id = yield self.store.get_federation_out_pos("federation")
defer.returnValue({
"federation": stream_id,
+
+ # Ack stuff we've "processed", this should only be called from
+ # one process.
"federation_ack": stream_id,
})
|