You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by ma...@apache.org on 2012/08/27 18:48:03 UTC
svn commit: r1377740 - in
/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine:
PrioritizedQueueBasedWorkflowEngine.java
processor/WorkflowProcessorQueue.java
Author: mattmann
Date: Mon Aug 27 16:48:03 2012
New Revision: 1377740
URL: http://svn.apache.org/viewvc?rev=1377740&view=rev
Log:
- OODT-310 WIP: remove extraneous System.out.printlns
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngine.java
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorQueue.java
Modified: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngine.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngine.java?rev=1377740&r1=1377739&r2=1377740&view=diff
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngine.java (original)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngine.java Mon Aug 27 16:48:03 2012
@@ -124,7 +124,6 @@ public class PrioritizedQueueBasedWorkfl
WorkflowState state = cycle.getStateByName("Queued");
state.setMessage("Workflow started and Queued.");
inst.setState(state);
- System.out.println("CATEGORY NAME: ["+inst.getState().getCategory().getName()+"]");
try {
this.repo.addWorkflowInstance(inst);
} catch (InstanceRepositoryException e) {
Modified: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorQueue.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorQueue.java?rev=1377740&r1=1377739&r2=1377740&view=diff
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorQueue.java (original)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorQueue.java Mon Aug 27 16:48:03 2012
@@ -90,8 +90,6 @@ public class WorkflowProcessorQueue {
if ((inst.getState() == null)
|| (inst.getState() != null && inst.getState().getCategory() == null)) {
WorkflowLifecycle cycle = getLifecycle(inst.getWorkflow());
- System.out.println("I AM SETTING the state to get state by name: ["
- + inst.getStatus() + "]");
WorkflowState state = cycle.getStateByName(inst.getStatus());
state.setMessage("Queued by WorkflowProcessorQueue.");
inst.setState(state);
@@ -106,9 +104,6 @@ public class WorkflowProcessorQueue {
+ e.getMessage());
}
- } else {
- System.out.println("NOT CHANGING state: info for inst: "
- + inst.getState());
}
processors.add(fromWorkflowInstance(inst));
}
@@ -158,7 +153,6 @@ public class WorkflowProcessorQueue {
processor.setConditionProcessor(false);
processor.setDynamicMetadata(inst.getSharedContext());
processor.setPriority(inst.getPriority());
- System.out.println("processor state: [" + processor.getState() + "]");
ProcessorDateTimeInfo dateTimeInfo = new ProcessorDateTimeInfo();
processor.setProcessorDateTimeInfo(dateTimeInfo);
processor.setStaticMetadata(new Metadata());