Start pushers on reactor thread

This commit is contained in:
Erik Johnston 2015-04-29 18:22:20 +01:00
parent 3864b3a8e6
commit 46daf2d200

View File

@ -19,6 +19,8 @@ from twisted.internet import defer
from httppusher import HttpPusher from httppusher import HttpPusher
from synapse.push import PusherConfigException from synapse.push import PusherConfigException
from synapse.util.async import run_on_reactor
import logging import logging
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -48,6 +50,7 @@ class PusherPool:
@defer.inlineCallbacks @defer.inlineCallbacks
def start(self): def start(self):
yield run_on_reactor()
pushers = yield self.store.get_all_pushers() pushers = yield self.store.get_all_pushers()
self._start_pushers(pushers) self._start_pushers(pushers)