Merge branch 'master' of ssh://dev.cccs.uwe.ac.uk:22/var/git/cristal-kernel

1 files changed, 9 insertions, 2 deletions

diff --git a/src/main/java/com/c2kernel/entity/ItemImplementation.java b/src/main/java/com/c2kernel/entity/ItemImplementation.java
index b12e105..9aa4f9b 100644
--- a/src/main/java/com/c2kernel/entity/ItemImplementation.java
+++ b/src/main/java/com/c2kernel/entity/ItemImplementation.java
@@ -11,6 +11,8 @@ import com.c2kernel.common.PersistencyException;
 import com.c2kernel.entity.agent.JobArrayList;

 import com.c2kernel.lifecycle.instance.CompositeActivity;

 import com.c2kernel.lifecycle.instance.Workflow;

+import com.c2kernel.lifecycle.instance.predefined.PredefinedStepContainer;

+import com.c2kernel.lifecycle.instance.predefined.item.ItemPredefinedStepContainer;

 import com.c2kernel.lookup.AgentPath;

 import com.c2kernel.lookup.InvalidItemPathException;

 import com.c2kernel.persistency.ClusterStorage;

@@ -75,10 +77,10 @@ public class ItemImplementation implements ItemOperations {
 		try {

 			Workflow lc = null;

 			if (initWfString == null || initWfString.length() == 0)

-				lc = new Workflow(new CompositeActivity());

+				lc = new Workflow(new CompositeActivity(), getNewPredefStepContainer());

 			else

 				lc = new Workflow((CompositeActivity) Gateway

-						.getMarshaller().unmarshall(initWfString));

+						.getMarshaller().unmarshall(initWfString), getNewPredefStepContainer());

 			lc.initialise(mSystemKey, agentPath);

 			mStorage.put(mSystemKey, lc, locker);

 		} catch (Throwable ex) {

@@ -112,6 +114,11 @@ public class ItemImplementation implements ItemOperations {
 	}

 

 

+	protected PredefinedStepContainer getNewPredefStepContainer() {

+		

+		return new ItemPredefinedStepContainer();

+	}

+

 	@Override

 	public String requestAction(int agentId, String stepPath, int transitionID,

 			String requestData) throws AccessRightsException,