[metcat] r185 committed - removed Testing code from the trunk

[metcat.apach...@codespot.com]

Revision: 185
Author: mail.ha...@gmail.com
Date: Tue Aug 28 21:57:32 2012
Log: removed Testing code from the trunk
http://code.google.com/a/apache-extras.org/p/metcat/source/detail?r=185

Modified:
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/Server.java

/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/dispatcher/Dispatcher.java

/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/monitor/WorkflowMonitor.java

=======================================
---
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/Server.java
Tue Aug 28 02:58:30 2012
+++
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/Server.java
Tue Aug 28 21:57:32 2012
@@ -48,7 +48,6 @@
new ModelCreator().init();
dispatcher = new Dispatcher();
new Thread(dispatcher).start();
- //new Thread(new WorkflowTimeoutManager()).start();
}

public void startService() throws Exception {
@@ -59,26 +58,6 @@
//Starting Query Service
queryService = new QueryService(props.getQueryServicePort());
queryService.start();
-
-// // Input thought Monitor Thread Testing purpose only
-// new Thread(new Runnable() {
-// @Override
-// public void run() {
-// DispatchQueue queue = DispatchQueue.getInstance();
-// monitor.getI();
-// logger.fatal(" TS // Queue // monitor // dispatch //
source");
-// while (true)
-// {
-//
logger.fatal(Calendar.getInstance().getTimeInMillis() +
-// " // " + queue.getQueueSize() + " // " +
monitor.getI() + " // " + dispatcher.getI());
-// try {
-// Thread.sleep(1000);
-// } catch (InterruptedException e) {
-// e.printStackTrace();
-// }
-// }
-// }
-// }).start();
}

public void stopService() throws AxisFault {
=======================================
---
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/dispatcher/Dispatcher.java
Mon Aug 27 20:40:24 2012
+++
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/dispatcher/Dispatcher.java
Tue Aug 28 21:57:32 2012
@@ -61,16 +61,7 @@
doc = queue.getMsgFromQueue();
if (doc != null) {
try {
- dispatch(doc);
-
-// /* For testing purpose */
-// i++;
-// if(i==1){
-//
logger.fatal(java.util.Calendar.getInstance().getTimeInMillis() +
-// " // " + queue.getQueueSize() + " // // "
+ getI() + " // [Dispatch thread "+ this.toString() + "started]" );
-//
-// }
-
+ dispatch(doc);
} catch (Exception e) {
e.printStackTrace();
}
@@ -97,14 +88,5 @@

return type;
}
-
- /**
- * Returns Message count
- * @return int
- */
- public int getI()
- {
- return i;
- }

}
=======================================
---
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/monitor/WorkflowMonitor.java
Tue Aug 28 01:56:38 2012
+++
/trunk/metcatserver/src/main/java/org/apache/airavata/metcat/monitor/WorkflowMonitor.java
Tue Aug 28 21:57:32 2012
@@ -80,13 +80,6 @@
try {
Document document =
XMLUtils.toDOM(soapEnvelope.getBody().getFirstElement());
queue.addMsgToQueue(document);
-
- /* For testing purpose */
-// i++;
-// if(i==1){
-//
logger.fatal(java.util.Calendar.getInstance().getTimeInMillis() +
-// " // " + queue.getQueueSize() + " // " +
getI() + " // // [Monitor started]" );
-// }

} catch (Exception e) {
logger.warn(e);
@@ -158,15 +151,6 @@
}
}
}
-
- /**
- * Returns message count
- *
- * @return count
- */
- public int getI() {
- return i;
- }

}