From b912d4dca9e5c44c2acb68b4cbe2945302648692 Mon Sep 17 00:00:00 2001
From: "roberto.cirillo" <roberto.cirillo>
Date: Mon, 27 Oct 2014 14:48:59 +0000
Subject: [PATCH] added folderAccountingConsumer but disabled for this release
 (3.5)

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/content-management/storage-manager-trigger@101031 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 .../storageserver/data/ReadingMongoOplog.java        | 12 ++++++++++--
 .../storageserver/startup/Startup.java               | 12 ++++++------
 2 files changed, 16 insertions(+), 8 deletions(-)

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) {