You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2015/03/13 22:16:32 UTC

svn commit: r1666586 - in /uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance: MaintenanceThread.java MqHelper.java MqReaper.java

Author: degenaro
Date: Fri Mar 13 21:16:32 2015
New Revision: 1666586

URL: http://svn.apache.org/r1666586
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath

Jettison MqReaper code.

Removed:
    uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MqHelper.java
    uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MqReaper.java
Modified:
    uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MaintenanceThread.java

Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MaintenanceThread.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MaintenanceThread.java?rev=1666586&r1=1666585&r2=1666586&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MaintenanceThread.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/maintenance/MaintenanceThread.java Fri Mar 13 21:16:32 2015
@@ -101,14 +101,6 @@ public class MaintenanceThread extends T
 				if(isTime()) {
 					stateManager.prune(workMap);
 					healthMonitor.ajudicate();
-					try {
-						MqReaper mqReaper = MqReaper.getInstance();
-						mqReaper.removeUnusedJdQueues(workMap);
-					}
-					catch(Exception e) {
-						MqReaper.resetInstance();
-					}
-					
 				}
 			}
 			catch(Throwable t) {