diff options
| author | Mark Haines <mark.haines@matrix.org> | 2014-08-26 18:57:17 +0100 |
|---|---|---|
| committer | Mark Haines <mark.haines@matrix.org> | 2014-08-26 18:57:17 +0100 |
| commit | 6966971a28bb6dfed3daef6e5cd2e41b1ce34788 (patch) | |
| tree | f1b859319060fa6d8578cb14e80fc8d517097d23 /synapse/federation/replication.py | |
| parent | Move new event boilerplate in room handlers into a method on a base clase. (diff) | |
| download | synapse-6966971a28bb6dfed3daef6e5cd2e41b1ce34788.tar.xz | |
Use store.persist_event rather than pdu_actions.persist_outgoing/pdu_actions.persist_received
Diffstat (limited to 'synapse/federation/replication.py')
| -rw-r--r-- | synapse/federation/replication.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/federation/replication.py b/synapse/federation/replication.py index cf634a64b2..731cb74dd2 100644 --- a/synapse/federation/replication.py +++ b/synapse/federation/replication.py @@ -137,7 +137,7 @@ class ReplicationLayer(object): #yield self.pdu_actions.populate_previous_pdus(pdu) # Save *before* trying to send - yield self.pdu_actions.persist_outgoing(pdu) + yield self.store.persist_event(pdu=pdu) logger.debug("[%s] Persisted PDU", pdu.pdu_id) logger.debug("[%s] transaction_layer.enqueue_pdu... ", pdu.pdu_id) @@ -450,7 +450,7 @@ class ReplicationLayer(object): logger.exception("Failed to get PDU") # Persist the Pdu, but don't mark it as processed yet. - yield self.pdu_actions.persist_received(pdu) + yield self.store.persist_event(pdu=pdu) if not backfilled: ret = yield self.handler.on_receive_pdu(pdu, backfilled=backfilled) |