1 files changed, 6 insertions, 5 deletions
diff --git a/same/src/main/java/com/orbekk/same/DiscoveryService.java b/same/src/main/java/com/orbekk/same/DiscoveryService.java
index d9af9bb..1987c69 100644
--- a/same/src/main/java/com/orbekk/same/DiscoveryService.java
+++ b/same/src/main/java/com/orbekk/same/DiscoveryService.java
@@ -11,13 +11,14 @@ public class DiscoveryService extends Thread {
     private Logger logger = LoggerFactory.getLogger(getClass());
     BroadcastListener broadcastListener;
     DiscoveryListener listener;
-    
+
     public DiscoveryService(DiscoveryListener listener,
             BroadcastListener broadcastListener) {
         this.listener = listener;
         this.broadcastListener = broadcastListener;
     }
-    
+
+    @Override
     public void run() {
         logger.info("DiscoveryService starting.");
         while (!Thread.interrupted()) {
@@ -28,12 +29,12 @@ public class DiscoveryService extends Thread {
             }
             String content = new String(packet.getData(), 0, packet.getLength());
             String[] words = content.split(" ");
-            
+
             if (!content.startsWith("Discover") || words.length < 2) {
                 logger.warn("Invalid discovery message: {}", content);
                 continue;
             }
-            
+
             String url = words[1];
             logger.info("Received discovery from {}", url);
             if (listener != null) {
@@ -42,7 +43,7 @@ public class DiscoveryService extends Thread {
         }
         logger.info("DiscoveryService stopped.");
     }
-    
+
     @Override public void interrupt() {
         logger.info("Interrupt()");
         super.interrupt();