Removing possible stop condition

api/src/main/java/org/open4goods/api/config/yml/ApiProperties.java

@@ -114,11 +114,6 @@ public class ApiProperties {
 	 */
 	private Integer dataFragmentsDequeueSize = 200;
 
-	/**
-	 * The datafragments dequeue worker size
-	 */
-	private Integer dataFragmentsDequeueWorkers = 4;
-
 	/**
 	 * The datafragments worker dequeue poll period, in ms
 	 */
@@ -403,20 +398,6 @@ public void setRootFolder(final String rootFolder) {
 
 
 
-
-
-	public Integer getDataFragmentsDequeueWorkers() {
-		return dataFragmentsDequeueWorkers;
-	}
-
-
-
-	public void setDataFragmentsDequeueWorkers(Integer dataFragmentsDequeueWorker) {
-		dataFragmentsDequeueWorkers = dataFragmentsDequeueWorker;
-	}
-
-
-
 	public boolean isOperatesNlpProcessing() {
 		return operatesNlpProcessing;
 	}

crawler/src/main/java/org/open4goods/crawler/services/fetching/CsvDatasourceFetchingService.java

@@ -101,7 +101,6 @@ public void start(final DataSourceProperties pConfig, final String datasourceCon
 	@Override
 	public void stop(final String providerName) {
 		indexationService.clearIndexedCounter(providerName);
-		runningJobs.get(providerName).stop();
 	}
 
 	@Override

crawler/src/main/java/org/open4goods/crawler/services/fetching/CsvIndexationWorker.java

@@ -89,7 +89,7 @@ public class CsvIndexationWorker implements Runnable {
 	/**
 	 * State flag
 	 */
-	private volatile boolean stop;
+//	private volatile boolean stop;
 
 	/**
 	 * The externaly maintained stats
@@ -117,7 +117,7 @@ public CsvIndexationWorker(final CsvDatasourceFetchingService csvService, DataFr
 
 	@Override
 	public void run() {
-		while (!stop) {
+		while (true) {
 			try {
 				if (!csvService.getQueue().isEmpty()) {
 					// There is data to consume and queue consummation is enabled
@@ -696,13 +696,6 @@ private List<String> getCategoryFromCsvRows(Map<String, String> item) {
 		return ret;
 	}
 
-	/**
-	 * Say this thread to stop
-	 */
-	public void stop() {
-		this.stop = true;
-	}
-
 	public synchronized IndexationJobStat stats() {
 		return stats;
 	}