diff --git a/src/main/java/org/gcube/contentmanager/storageserver/data/ReadingMongoOplog.java b/src/main/java/org/gcube/contentmanager/storageserver/data/ReadingMongoOplog.java index 61b46b9..f8fbd88 100644 --- a/src/main/java/org/gcube/contentmanager/storageserver/data/ReadingMongoOplog.java +++ b/src/main/java/org/gcube/contentmanager/storageserver/data/ReadingMongoOplog.java @@ -88,12 +88,20 @@ public class ReadingMongoOplog extends Thread{ }else{ logger.debug("record discarded: \t"+x); } - + try { + Thread.sleep(20000); + } catch (InterruptedException e1) { + // TODO Auto-generated catch block + e1.printStackTrace(); + } } try { Thread.sleep(1000); - } catch (InterruptedException e) { + } catch (InterruptedException e1) { + // TODO Auto-generated catch block + e1.printStackTrace(); } + } } diff --git a/src/main/java/org/gcube/contentmanager/storageserver/startup/Startup.java b/src/main/java/org/gcube/contentmanager/storageserver/startup/Startup.java index 3da769d..ccbef62 100644 --- a/src/main/java/org/gcube/contentmanager/storageserver/startup/Startup.java +++ b/src/main/java/org/gcube/contentmanager/storageserver/startup/Startup.java @@ -55,14 +55,14 @@ public class Startup { ssConsumer=new UserAccountingConsumer(server, c1, 1, dtsHosts); else ssConsumer=new UserAccountingConsumer(server, args[1], args[2], c1, 1, dtsHosts); - FolderAccountingConsumer fsConsumer=null; - if(args.length == 3) - fsConsumer=new FolderAccountingConsumer(server, c2, 1); - else - fsConsumer=new FolderAccountingConsumer(server, args[1], args[2], c2, 1); +// FolderAccountingConsumer fsConsumer=null; +// if(args.length == 3) +// fsConsumer=new FolderAccountingConsumer(server, c2, 1); +// else +// fsConsumer=new FolderAccountingConsumer(server, args[1], args[2], c2, 1); producer.start(); ssConsumer.start(); - fsConsumer.start(); +// fsConsumer.start(); } private static String[] retrieveServerConfiguration(Configuration c) {