diff options
| author | Kegan Dougal <kegan@matrix.org> | 2015-03-16 10:16:59 +0000 |
|---|---|---|
| committer | Kegan Dougal <kegan@matrix.org> | 2015-03-16 10:16:59 +0000 |
| commit | 835e01fc7047e34a813936544027596627a112df (patch) | |
| tree | 3cc833fa3756b7e21750c17f498bf438298cef1f /synapse/appservice/scheduler.py | |
| parent | Merge branch 'develop' into application-services-txn-reliability (diff) | |
| download | synapse-835e01fc7047e34a813936544027596627a112df.tar.xz | |
Minor PR comment tweaks.
Diffstat (limited to 'synapse/appservice/scheduler.py')
| -rw-r--r-- | synapse/appservice/scheduler.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/appservice/scheduler.py b/synapse/appservice/scheduler.py index add1e3879c..8a3a6a880f 100644 --- a/synapse/appservice/scheduler.py +++ b/synapse/appservice/scheduler.py @@ -86,7 +86,7 @@ class AppServiceScheduler(object): self.txn_ctrl.start_polling() def submit_event_for_as(self, service, event): - self.event_grouper.on_receive(service, event) + self.event_grouper.enqueue(service, event) class _EventGrouper(object): @@ -96,7 +96,7 @@ class _EventGrouper(object): def __init__(self): self.groups = {} # dict of {service: [events]} - def on_receive(self, service, event): + def enqueue(self, service, event): if service not in self.groups: self.groups[service] = [] self.groups[service].append(event) |