diff --git a/src/tweets/collector.py b/src/tweets/collector.py
index b138ebf..97b2c34 100644
--- a/src/tweets/collector.py
+++ b/src/tweets/collector.py
@@ -70,9 +70,13 @@ class Streamer():
                 stream.filter(languages=["en"], track=hashtag)
             except IncompleteRead:
                 log("Incomplete Read Error", 'ERR')
+                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
+                stream.filter(languages=["en"], track=hashtag)
                 continue
             except ProtocolError:
                 log("Protocol Error", 'ERR')
+                stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
+                stream.filter(languages=["en"], track=hashtag)
                 continue
 
 class Listener(StreamListener):
@@ -146,16 +150,10 @@ def processTweet(text, type):
 def collector(hashtag):
 
     log("Thread Start...", 'INFO')
-    schedule.clear("collectTweets")
-
-    global timeF
-    timeF = timeFunction()
 
     streamer = Streamer()
     streamer.stream_tweets(hashtag)
 
-    schedule.every().hour.at(timeF).do(createHourJob).tag("collectTweets")
-
 def timeFunction():
     global timeF