From 34ad0c5e473a616f1ed9571dca129c8faf7777e1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Manuel=20Cort=C3=A9z?= Date: Wed, 12 Aug 2015 16:43:23 -0500 Subject: [PATCH] Reconnecting streams every 5 mins --- src/controller/mainController.py | 4 ++-- src/sessionmanager/session.py | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/controller/mainController.py b/src/controller/mainController.py index 9b6cb516..91f87cc7 100644 --- a/src/controller/mainController.py +++ b/src/controller/mainController.py @@ -125,7 +125,7 @@ class Controller(object): log.debug("Binding other application events...") pub.subscribe(self.logout_account, "logout") pub.subscribe(self.login_account, "login") - pub.subscribe(self.manage_stream_errors, "stream-error") + pub.subscribe(self.manage_stream_errors, "streamError") pub.subscribe(self.create_new_buffer, "create-new-buffer") pub.subscribe(self.restart_streams, "restart-streams") @@ -1204,7 +1204,7 @@ class Controller(object): session.start_streaming() def manage_stream_errors(self, session): - log.error("An error ocurred with the stream for the %s session. It will be destroyed" % (session,)) + log.debug(" Restarting %s session streams. It will be destroyed" % (session,)) s = session_.sessions[session] for i in self.buffers: if i.invisible == True and i.session.session_id == s.session_id: diff --git a/src/sessionmanager/session.py b/src/sessionmanager/session.py index 7d4df8b1..84e26264 100644 --- a/src/sessionmanager/session.py +++ b/src/sessionmanager/session.py @@ -344,6 +344,7 @@ class Session(object): self.logged = False self.twitter = twitter.twitter.twitter() self.login(False) + pub.sendMessage("streamError", session=self.session_id) if self.reconnection_function_active == True: return self.reconnection_function_active = True if not hasattr(self, "main_stream"):