You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by bf...@apache.org on 2011/03/02 22:30:20 UTC
svn commit: r1076393 - in /oodt/branches/wengine-branch/wengine/src/main:
java/org/apache/oodt/cas/workflow/instance/ resources/policy/workflows/
Author: bfoster
Date: Wed Mar 2 21:30:19 2011
New Revision: 1076393
URL: http://svn.apache.org/viewvc?rev=1076393&view=rev
Log:
- updates to WorkflowConnectionTaskInstance
----------------------------
Added:
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/SimpleNMetadataModification.java (with props)
Modified:
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
oodt/branches/wengine-branch/wengine/src/main/resources/policy/workflows/WorkflowModelTestFile.xml
Added: oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/SimpleNMetadataModification.java
URL: http://svn.apache.org/viewvc/oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/SimpleNMetadataModification.java?rev=1076393&view=auto
==============================================================================
--- oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/SimpleNMetadataModification.java (added)
+++ oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/SimpleNMetadataModification.java Wed Mar 2 21:30:19 2011
@@ -0,0 +1,15 @@
+package org.apache.oodt.cas.workflow.instance;
+
+import org.apache.oodt.cas.metadata.Metadata;
+
+public class SimpleNMetadataModification implements WorkflowConnectTaskInstance.NMetadataModification {
+
+ public static final String I = "SimpleNMetadataModification/I";
+ public static final String N = "SimpleNMetadataModification/N";
+
+ public void prepare(int i, int n, Metadata metadata) {
+ metadata.replaceMetadata(I, Integer.toString(i));
+ metadata.replaceMetadata(N, Integer.toString(n));
+ }
+
+}
Propchange: oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/SimpleNMetadataModification.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Modified: oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
URL: http://svn.apache.org/viewvc/oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java?rev=1076393&r1=1076392&r2=1076393&view=diff
==============================================================================
--- oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java (original)
+++ oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java Wed Mar 2 21:30:19 2011
@@ -76,7 +76,7 @@ public class WorkflowConnectTaskInstance
for (int i = 0; i < n; i++) {
Metadata curWorkflowMet = new Metadata(spawnWorkflowMet);
if (nMetMod != null)
- nMetMod.prepare(n, curWorkflowMet);
+ nMetMod.prepare(i, n, curWorkflowMet);
try {
curWorkflowMet.replaceMetadata(SPAWNED_BY_WORKFLOW, this.getInstanceId());
spawnedInstanceId.add(this.weClient.startWorkflow(spawnModelId, curWorkflowMet));
@@ -131,7 +131,7 @@ public class WorkflowConnectTaskInstance
public interface NMetadataModification {
- public void prepare(int n, Metadata metadata);
+ public void prepare(int i, int n, Metadata metadata);
}
Modified: oodt/branches/wengine-branch/wengine/src/main/resources/policy/workflows/WorkflowModelTestFile.xml
URL: http://svn.apache.org/viewvc/oodt/branches/wengine-branch/wengine/src/main/resources/policy/workflows/WorkflowModelTestFile.xml?rev=1076393&r1=1076392&r2=1076393&view=diff
==============================================================================
--- oodt/branches/wengine-branch/wengine/src/main/resources/policy/workflows/WorkflowModelTestFile.xml (original)
+++ oodt/branches/wengine-branch/wengine/src/main/resources/policy/workflows/WorkflowModelTestFile.xml Wed Mar 2 21:30:19 2011
@@ -11,6 +11,7 @@
<configuration>
<property name="WorkflowConnect/ModelId" value="TestConnectTask"/>
<property name="WorkflowConnect/NCalculator/Class" value="org.apache.oodt.cas.workflow.instance.SimpleNCalculator"/>
+ <property name="WorkflowConnect/NMetadataModifier/Class" value="org.apache.oodt.cas.workflow.instance.SimpleNMetadataModification"/>
<property name="SimpleNCalculator/N" value="3"/>
</configuration>
</task>