diff options
Diffstat (limited to 'same/src/main/java/com/orbekk/same/DiscoveryService.java')
-rw-r--r-- | same/src/main/java/com/orbekk/same/DiscoveryService.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/same/src/main/java/com/orbekk/same/DiscoveryService.java b/same/src/main/java/com/orbekk/same/DiscoveryService.java index bc28a58..0415316 100644 --- a/same/src/main/java/com/orbekk/same/DiscoveryService.java +++ b/same/src/main/java/com/orbekk/same/DiscoveryService.java @@ -12,13 +12,14 @@ public class DiscoveryService extends Thread { BroadcastListener broadcastListener; DiscoveryListener listener; - public DiscoveryService(int port, DiscoveryListener listener, + public DiscoveryService(DiscoveryListener listener, BroadcastListener broadcastListener) { this.listener = listener; this.broadcastListener = broadcastListener; } public void run() { + logger.info("DiscoveryService starting."); while (!Thread.interrupted()) { DatagramPacket packet = broadcastListener.listen(); String content = new String(packet.getData(), 0, packet.getLength()); @@ -35,9 +36,11 @@ public class DiscoveryService extends Thread { listener.discover(url); } } + logger.info("DiscoveryService stopped."); } @Override public void interrupt() { + logger.info("Interrupt()"); super.interrupt(); broadcastListener.interrupt(); } |