diff options
author | Mark Haines <mark.haines@matrix.org> | 2015-12-02 11:36:02 +0000 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2015-12-02 11:36:02 +0000 |
commit | 37b2d69bbcdc8df40712799bf438a7c1463b5bc2 (patch) | |
tree | 6aacd741e21a8603e9fb636f8f8adf54a8617328 /synapse/push | |
parent | Fix typo in collect_presencelike_data (diff) | |
download | synapse-37b2d69bbcdc8df40712799bf438a7c1463b5bc2.tar.xz |
Reuse a single http client, rather than creating new ones
Diffstat (limited to 'synapse/push')
-rw-r--r-- | synapse/push/httppusher.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py index a02fed57b4..5160775e59 100644 --- a/synapse/push/httppusher.py +++ b/synapse/push/httppusher.py @@ -14,7 +14,6 @@ # limitations under the License. from synapse.push import Pusher, PusherConfigException -from synapse.http.client import SimpleHttpClient from twisted.internet import defer @@ -46,7 +45,7 @@ class HttpPusher(Pusher): "'url' required in data for HTTP pusher" ) self.url = data['url'] - self.httpCli = SimpleHttpClient(self.hs) + self.http_client = _hs.get_simple_http_client() self.data_minus_url = {} self.data_minus_url.update(self.data) del self.data_minus_url['url'] @@ -107,7 +106,7 @@ class HttpPusher(Pusher): if not notification_dict: defer.returnValue([]) try: - resp = yield self.httpCli.post_json_get_json(self.url, notification_dict) + resp = yield self.http_client.post_json_get_json(self.url, notification_dict) except: logger.warn("Failed to push %s ", self.url) defer.returnValue(False) @@ -138,7 +137,7 @@ class HttpPusher(Pusher): } } try: - resp = yield self.httpCli.post_json_get_json(self.url, d) + resp = yield self.http_client.post_json_get_json(self.url, d) except: logger.exception("Failed to push %s ", self.url) defer.returnValue(False) |