Commit 4c03a2b5 authored by Wayne Moore's avatar Wayne Moore Committed by Joshua Roesslein
Browse files

Runtime exception in listener no longer fails silently (Fixed issue #14).

parent c96b8bd3
......@@ -89,6 +89,7 @@ class Stream(object):
# enter loop
error_counter = 0
conn = None
exception = None
while self.running:
if self.retry_count and error_counter > self.retry_count:
# quit if error count greater than retry count
......@@ -114,7 +115,7 @@ class Stream(object):
break
conn.close()
sleep(self.snooze_time)
except Exception:
except Exception, exception:
# any other exception is fatal, so kill loop
break
......@@ -123,6 +124,9 @@ class Stream(object):
if conn:
conn.close()
if exception:
raise exception
def _read_loop(self, resp):
data = ''
while self.running:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment