gCubeSystem
/
storage-manager-trigger
16
0
Fork 0
Code Issues Releases Wiki Activity

update input parameter manage 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/content-management/storage-manager-trigger@101569 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
roberto.cirillo 2014-11-11 10:04:53 +00:00
parent 5020663c03
commit 1325166a31
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/org/gcube/contentmanager/storageserver/startup/Startup.java
View File

@ -62,20 +62,26 @@ public class Startup {
private static void startUserAccountingConsumer(String[] args,
String[] server, List<String> dtsHosts, CubbyHole c1) {
UserAccountingConsumer ssConsumer=null;
if(args.length == 3)
if(args.length == 2)
ssConsumer=new UserAccountingConsumer(server, c1, 1, dtsHosts);
else
else if(args.length == 4)
ssConsumer=new UserAccountingConsumer(server, args[1], args[2], c1, 1, dtsHosts);
else{
throw new IllegalArgumentException("input parameter are incorrect");
}
ssConsumer.start();
}
private static void startProducer(String[] args, String oplogServer,
String[] server, CubbyHole c1, CubbyHole c2) {
ReadingMongoOplog producer=null;
if(args.length == 3)
if(args.length == 4)
producer=new ReadingMongoOplog( Arrays.asList(oplogServer), args[1], args[2], c1, c2, 1 );
else
else if(args.length == 2)
producer=new ReadingMongoOplog( Arrays.asList(server), c1, c2, 1 );
else{
throw new IllegalArgumentException("input parameter are incorrect");
}
producer.start();
}