diff --git a/squinnondation/peers.py b/squinnondation/peers.py index fa7dca3..31091e1 100644 --- a/squinnondation/peers.py +++ b/squinnondation/peers.py @@ -140,6 +140,7 @@ class User(Peer): self.listener = Listener(self) self.neighbour_manager = PeerManager(self) self.inondator = Inondator(self) + self.multicastlistener = Multicastlistener(self) self.add_system_message(f"Listening on {self.main_address[0]}:{self.main_address[1]}", ignore_debug=True) self.add_system_message(f"I am {self.id}") @@ -254,10 +255,12 @@ class User(Peer): self.listener.setDaemon(True) self.neighbour_manager.setDaemon(True) self.inondator.setDaemon(True) + self.multicastlistener.setDaemon(True) self.listener.start() self.neighbour_manager.start() self.inondator.start() + self.multicastlistener.start() def wait_for_key(self) -> None: """