diff --git a/plugins/AnnounceLocal/BroadcastServer.py b/plugins/AnnounceLocal/BroadcastServer.py index 9e1e489e..8e153413 100644 --- a/plugins/AnnounceLocal/BroadcastServer.py +++ b/plugins/AnnounceLocal/BroadcastServer.py @@ -60,6 +60,9 @@ class BroadcastServer(object): self.log.error("Listener receive error: %s" % err) continue + if not self.running: + break + try: message = msgpack.unpackb(data) response_addr, message = self.handleMessage(addr, message)