if self.default_server == server and self.interface:
return
+ if self.protocol != server.split(':')[2]:
+ return
+
# stop the interface in order to terminate subscriptions
if self.interface:
self.interface.stop()
while self.is_running():
try:
- i = self.queue.get(timeout = 30)
+ i = self.queue.get(timeout = 30 if self.interfaces else 3)
except Queue.Empty:
if len(self.interfaces) < NUM_SERVERS:
self.start_random_interface()