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>
