summary refs log tree commit diff
path: root/synapse/appservice/scheduler.py
diff options
context:
space:
mode:
authorKegan Dougal <kegan@matrix.org>2015-03-16 10:16:59 +0000
committerKegan Dougal <kegan@matrix.org>2015-03-16 10:16:59 +0000
commit835e01fc7047e34a813936544027596627a112df (patch)
tree3cc833fa3756b7e21750c17f498bf438298cef1f /synapse/appservice/scheduler.py
parentMerge branch 'develop' into application-services-txn-reliability (diff)
downloadsynapse-835e01fc7047e34a813936544027596627a112df.tar.xz
Minor PR comment tweaks.
Diffstat (limited to 'synapse/appservice/scheduler.py')
-rw-r--r--synapse/appservice/scheduler.py4
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)