#312

git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32904

diff --git a/server/hu.user.mediacube.indexer/src/main/java/hu/user/mediacube/indexer/service/IndexerService.java b/server/hu.user.mediacube.indexer/src/main/java/hu/user/mediacube/indexer/service/IndexerService.java
index 23e2b0639d222b6f366db16f8a0e2495b5ffa7de..7e772f75fc834abf48cede187170808b1f9934ed 100644 (file)
--- a/server/hu.user.mediacube.indexer/src/main/java/hu/user/mediacube/indexer/service/IndexerService.java
+++ b/server/hu.user.mediacube.indexer/src/main/java/hu/user/mediacube/indexer/service/IndexerService.java
@@ -1,4 +1,4 @@
-package hu.user.mediacube.indexer;\r
+package hu.user.mediacube.indexer.service;\r
 \r
 import static java.util.concurrent.TimeUnit.SECONDS;\r
 \r
@@ -16,6 +16,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;\r
 import org.springframework.stereotype.Component;\r
 \r
+import hu.user.mediacube.indexer.JsonProperties;\r
 import hu.user.mediacube.indexer.db.IndexerDescription;\r
 import hu.user.mediacube.indexer.db.IndexerViewMapper;\r
 import hu.user.mediacube.indexer.db.MediadescriptionMapper;\r
@@ -38,7 +39,7 @@ public class IndexerService implements Runnable {
        private JsonProperties config;\r
 \r
        @Override\r
-       //periodic task\r
+       // periodic task\r
        public void run() {\r
                logger.info("Reading index");\r
                List<IndexerDescription> indexerDescriptions = mapper.selectAll();\r
@@ -51,7 +52,7 @@ public class IndexerService implements Runnable {
 \r
                        String description = mapper.selectDescription(indexerDescription);\r
                        indexerDescription.setDescription(description);\r
-                       //logger.info("{}", indexerDescription);\r
+                       // logger.info("{}", indexerDescription);\r
                        boolean putLog = ++i % logStep == 0;\r
                        boolean lastRow = i == indexerDescriptions.size();\r
                        try {\r
@@ -65,7 +66,8 @@ public class IndexerService implements Runnable {
                                        logger.error("Index committed");\r
                                }\r
                        } catch (IOException e) {\r
-                               logger.error("Can not create index, caused by {} : {}", e.getClass().getSimpleName(), e.getMessage(), e);\r
+                               logger.error("Can not create index, caused by {} : {}", e.getClass().getSimpleName(), e.getMessage(),\r
+                                               e);\r
                                break;\r
                        }\r
 \r
@@ -73,21 +75,21 @@ public class IndexerService implements Runnable {
        }\r
 \r
        public void schedule() {\r
-               //              beeperHandle = scheduler.scheduleAtFixedRate(this, 0, 5, SECONDS);\r
+               // beeperHandle = scheduler.scheduleAtFixedRate(this, 0, 5, SECONDS);\r
                beeperHandle = scheduler.schedule(this, 0, SECONDS);\r
 \r
-               //              scheduler.schedule(new Runnable() {\r
-               //                      @Override\r
-               //                      public void run() {\r
-               //                              beeperHandle.cancel(true);\r
-               //                      }\r
-               //              }, 60 * 60, SECONDS);\r
+               // scheduler.schedule(new Runnable() {\r
+               // @Override\r
+               // public void run() {\r
+               // beeperHandle.cancel(true);\r
+               // }\r
+               // }, 60 * 60, SECONDS);\r
        }\r
 \r
-       //@PostConstruct\r
+       // @PostConstruct\r
        public void start() {\r
                logger.info("start");\r
-               //schedule();\r
+               // schedule();\r
                if (config.isResetIndex())\r
                        run();\r
        }\r
@@ -96,11 +98,11 @@ public class IndexerService implements Runnable {
        public void stop() {\r
                if (beeperHandle != null)\r
                        beeperHandle.cancel(true);\r
-               //              try {\r
-               //                      scheduler.awaitTermination(2, TimeUnit.SECONDS);\r
-               //              } catch (InterruptedException e) {\r
-               //                      logger.error("Scheduler termination error", e);\r
-               //              }\r
+               // try {\r
+               // scheduler.awaitTermination(2, TimeUnit.SECONDS);\r
+               // } catch (InterruptedException e) {\r
+               // logger.error("Scheduler termination error", e);\r
+               // }\r
                logger.info("stop");\r
        }\r
 }\r