From: Sweidan Omar <TFS\sweidan.omar>
Date: Thu, 27 Jan 2022 10:29:42 +0000 (+0000)
Subject: #312
X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=8fc52a6bb16d648604f41e0e4c35223dea226d7b;p=mediacube.git

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