Author: thomas.diesler(a)jboss.com Date: 2008-10-31 12:54:14 -0400 (Fri, 31 Oct 2008) New Revision: 2720 Modified: projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/model/SequenceFlow.java projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/runtime/Token.java projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/service/PersistenceService.java projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/test/ProcessCatalog.java projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessMarshaller.java projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessUnmarshaller.java projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/model/JAXBFlow.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/AbstractElementImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EndEventImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EventImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ExclusiveGatewayImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GateImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GatewayImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GroupImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InclusiveGatewayImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InputSetImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/MessageImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/NodeImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/OutputSetImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ParallelGatewayImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessDefinitionImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessStructureImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/PropertySupportImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/SequenceFlowImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/StartEventImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/TaskImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/UserTaskImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/DelegatingToken.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RunnableToken.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RuntimeContext.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TokenImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TransactionInterceptor.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/ExecutionServiceImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/HibernatePersistenceServiceImpl.java projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/InMemoryPersistenceServiceImpl.java projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/EndEventPersistenceTest.java projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/NodePersistenceTest.java projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/TaskPersistenceTest.java projects/spec/branches/tdiesler/modules/ri/src/test/resources/log4j.xml Log: wip Modified: projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/model/SequenceFlow.java =================================================================== --- projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/model/SequenceFlow.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/model/SequenceFlow.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -52,19 +52,14 @@ * Object is connected from. Note: there are restrictions as to what objects Sequence * Flow and Message Flow can connect. */ - Node getSourceRef(); + String getSourceRef(); /** * TargetRef is an attribute that identifies which Graphical Element the Connecting * Object is connected to. Note: there are restrictions as to what objects Sequence * Flow and Message Flow can connect. */ - Node getTargetRef(); - - /** - * Get the required target name - */ - String getTargetName(); + String getTargetRef(); /** * By default, the ConditionType of a Sequence Flow is None. This means that there is no evaluation at runtime to Modified: projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/runtime/Token.java =================================================================== --- projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/runtime/Token.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/runtime/Token.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -24,6 +24,7 @@ // $Id$ import org.hibernate.Session; +import org.jbpm.api.model.Process; import org.jbpm.api.model.SequenceFlow; /** @@ -56,6 +57,11 @@ TokenStatus getTokenStatus(); /** + * Get the associated {@link Process} + */ + Process getProcess(); + + /** * Get the associated {@link ExecutionContext} */ ExecutionContext getExecutionContext(); Modified: projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/service/PersistenceService.java =================================================================== --- projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/service/PersistenceService.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/service/PersistenceService.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -90,6 +90,7 @@ /** * Load the Node from persistent storage + * @param fetchEager TODO */ - public abstract <T extends Node> T loadNode(Session session, Class<T> clazz, ObjectName nodeID); + public abstract <T extends Node> T loadNode(Session session, Class<T> clazz, ObjectName nodeID, boolean fetchEager); } \ No newline at end of file Modified: projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/test/ProcessCatalog.java =================================================================== --- projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/test/ProcessCatalog.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/api/src/main/java/org/jbpm/api/test/ProcessCatalog.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -95,13 +95,13 @@ SequenceFlow startFlow = start.getOutFlow(); TestCase.assertNotNull("Start flow not null", startFlow); - TestCase.assertEquals("Task", startFlow.getTargetName()); + TestCase.assertEquals("Task", startFlow.getTargetRef()); TestCase.assertSame(start, startFlow.getSourceRef()); TestCase.assertSame(task, startFlow.getTargetRef()); SequenceFlow taskFlow = task.getOutFlow(); TestCase.assertNotNull("Task flow not null", taskFlow); - TestCase.assertEquals("End", taskFlow.getTargetName()); + TestCase.assertEquals("End", taskFlow.getTargetRef()); TestCase.assertSame(task, taskFlow.getSourceRef()); TestCase.assertSame(end, taskFlow.getTargetRef()); } Modified: projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessMarshaller.java =================================================================== --- projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessMarshaller.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessMarshaller.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -423,7 +423,7 @@ { throw new NotImplementedException("JBPM-1382", "Message Flow"); } - jaxb.setTargetName(flow.getTargetName()); + jaxb.setTargetRef(flow.getTargetRef()); return jaxb; } Modified: projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessUnmarshaller.java =================================================================== --- projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessUnmarshaller.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/ProcessUnmarshaller.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -359,15 +359,15 @@ if (jaxbSeq.getConditionType() == ConditionType.Expression) { JAXBExpression jaxbExpr = jaxbSeq.getCondition(); - gwBuilder.addConditionalGate(jaxbFlow.getTargetName(), jaxbExpr.getLang(), jaxbExpr.getBody()); + gwBuilder.addConditionalGate(jaxbFlow.getTargetRef(), jaxbExpr.getLang(), jaxbExpr.getBody()); } else if (jaxbSeq.getConditionType() == ConditionType.Default) { - gwBuilder.addDefaultGate(jaxbFlow.getTargetName()); + gwBuilder.addDefaultGate(jaxbFlow.getTargetRef()); } else { - gwBuilder.addGate(jaxbFlow.getTargetName()); + gwBuilder.addGate(jaxbFlow.getTargetRef()); } } else if (jaxbFlow instanceof JAXBMessageFlow) @@ -390,7 +390,7 @@ { if (jaxbFlow instanceof JAXBSequenceFlow) { - procBuilder.addSequenceFlow(jaxbFlow.getTargetName()); + procBuilder.addSequenceFlow(jaxbFlow.getTargetRef()); } else if (jaxbFlow instanceof JAXBMessageFlow) { Modified: projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/model/JAXBFlow.java =================================================================== --- projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/model/JAXBFlow.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/dialects/api10/src/main/java/org/jbpm/dialect/api10/model/JAXBFlow.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -39,16 +39,16 @@ @XmlType(name = "Flow") public class JAXBFlow extends JAXBGraphicalElement { - private String targetName; + private String targetRef; - public String getTargetName() + public String getTargetRef() { - return targetName; + return targetRef; } @XmlAttribute(name = "to", required = true) - public void setTargetName(String targetName) + public void setTargetRef(String targetRef) { - this.targetName = targetName; + this.targetRef = targetRef; } } \ No newline at end of file Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/AbstractElementImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/AbstractElementImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/AbstractElementImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -29,6 +29,7 @@ import javax.persistence.Id; import javax.persistence.MappedSuperclass; +import org.hibernate.Session; import org.jbpm.api.InvalidProcessException; import org.jbpm.api.client.ProcessEngine; import org.jbpm.api.model.Process; @@ -81,6 +82,9 @@ return ProcessEngine.getProcessEngine(engineName); } + /** Initializes the persistent object */ + public abstract void initialize(Session session); + protected void create(ProcessDefinition procDef) { // nothing to do Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EndEventImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EndEventImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EndEventImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -103,7 +103,7 @@ public void setInFlow(SequenceFlowImpl inFlow) { inFlow.setTargetIndex(inFlows.size()); - inFlow.setTargetRef(this); + inFlow.setTargetRef(getName()); inFlows.add(inFlow); } Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EventImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EventImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/EventImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -27,7 +27,6 @@ import javax.persistence.CascadeType; import javax.persistence.EnumType; import javax.persistence.Enumerated; -import javax.persistence.FetchType; import javax.persistence.MappedSuperclass; import javax.persistence.OneToOne; @@ -66,10 +65,10 @@ @Enumerated(EnumType.STRING) protected EventDetailType detailType = EventDetailType.None; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = MessageImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = MessageImpl.class) private Message messageRef; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = SignalImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = SignalImpl.class) private Signal signalRef; public EventImpl(ProcessStructure procStruct, String name) Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ExclusiveGatewayImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ExclusiveGatewayImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ExclusiveGatewayImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -124,7 +124,7 @@ public void execute(TokenExecutor tokenExecutor, Token token) { - Node sourceRef = token.getSequenceFlow().getSourceRef(); + String sourceRef = token.getSequenceFlow().getSourceRef(); // Schedule the first token that arrives if (token == receivedTokens.get(0)) Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GateImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GateImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GateImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -29,7 +29,6 @@ import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.OneToMany; @@ -65,11 +64,11 @@ @GeneratedValue protected Integer id; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = SequenceFlowImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = SequenceFlowImpl.class) protected SequenceFlow outFlow; @IndexColumn(name = "assignIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = AssignmentImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = AssignmentImpl.class) private List<Assignment> assignments = new ArrayList<Assignment>(); @Override Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GatewayImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GatewayImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GatewayImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -103,7 +103,7 @@ public void addOutFlow(SequenceFlowImpl outFlow) { outFlow.setSourceIndex(outFlows.size()); - outFlow.setSourceRef(this); + outFlow.setSourceRef(getName()); outFlows.add(outFlow); } @@ -111,7 +111,7 @@ public void addInFlow(SequenceFlowImpl inFlow) { inFlow.setTargetIndex(inFlows.size()); - inFlow.setTargetRef(this); + inFlow.setTargetRef(getName()); inFlows.add(inFlow); } @@ -139,7 +139,7 @@ SequenceFlow gate = null; for (SequenceFlow aux : outFlows) { - if (aux.getTargetName().equals(targetName)) + if (aux.getTargetRef().equals(targetName)) { gate = aux; break; Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GroupImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GroupImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/GroupImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -30,7 +30,6 @@ import javax.persistence.Entity; import javax.persistence.EnumType; import javax.persistence.Enumerated; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.OneToOne; @@ -53,7 +52,7 @@ @Id @GeneratedValue protected int id; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertySupportImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = PropertySupportImpl.class) private PropertySupport propSupport = new PropertySupportImpl(); @Enumerated(EnumType.STRING) Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InclusiveGatewayImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InclusiveGatewayImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InclusiveGatewayImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -84,7 +84,7 @@ public void execute(TokenExecutor tokenExecutor, Token token) { MutableToken mutableToken = (MutableToken)token; - Node sourceRef = token.getSequenceFlow().getSourceRef(); + String sourceRef = token.getSequenceFlow().getSourceRef(); log.debug("Propagate token comming from: " + sourceRef); // Get the applicable gates Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InputSetImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InputSetImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/InputSetImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -28,7 +28,6 @@ import javax.persistence.Basic; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.OneToOne; @@ -54,7 +53,7 @@ @Basic private int setIndex; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertySupportImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = PropertySupportImpl.class) protected PropertySupport propSupport = new PropertySupportImpl(); int getSetIndex() Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/MessageImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/MessageImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/MessageImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -28,7 +28,6 @@ import javax.persistence.Basic; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.OneToOne; @@ -60,13 +59,13 @@ @Basic private String name; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = ParticipantImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = ParticipantImpl.class) private Participant fromRef; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = ParticipantImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = ParticipantImpl.class) private Participant toRef; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertySupportImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = PropertySupportImpl.class) protected PropertySupport propSupport = new PropertySupportImpl(); public MessageImpl(String name) Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/NodeImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/NodeImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/NodeImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -31,13 +31,14 @@ import javax.persistence.Basic; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.Inheritance; import javax.persistence.InheritanceType; import javax.persistence.ManyToOne; import javax.persistence.OneToMany; import javax.persistence.OneToOne; +import org.hibernate.Hibernate; +import org.hibernate.Session; import org.hibernate.annotations.IndexColumn; import org.jbpm.api.InvalidProcessException; import org.jbpm.api.NameNotUniqueException; @@ -91,18 +92,18 @@ private int nodeIndex; @IndexColumn(name = "targetIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, mappedBy = "targetRef", targetEntity = SequenceFlowImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = SequenceFlowImpl.class) protected List<SequenceFlow> inFlows = new ArrayList<SequenceFlow>(); @IndexColumn(name = "sourceIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, mappedBy = "sourceRef", targetEntity = SequenceFlowImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = SequenceFlowImpl.class) protected List<SequenceFlow> outFlows = new ArrayList<SequenceFlow>(); - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertySupportImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = PropertySupportImpl.class) protected PropertySupport propSupport = new PropertySupportImpl(); @IndexColumn(name = "assignIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = AssignmentImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = AssignmentImpl.class) private List<Assignment> assignments = new ArrayList<Assignment>(); @Basic @@ -233,12 +234,12 @@ public List<SequenceFlow> getInFlows() { - return inFlows; + return Collections.unmodifiableList(inFlows); } public List<SequenceFlow> getOutFlows() { - return outFlows; + return Collections.unmodifiableList(outFlows); } public void execute(RuntimeContext rtContext) @@ -398,6 +399,20 @@ checkAndInitializeStructure(procStruct); } + @Override + public void initialize(Session session) + { + Hibernate.initialize(this); + getProperties(); + getAssignments(); + for (SequenceFlow flow : getOutFlows()) + { + String targetRef = flow.getTargetRef(); + System.out.println(targetRef); + } + getInFlows(); + } + private void checkAndInitializeStructure(ProcessStructure procStruct) { // Check required name @@ -467,7 +482,7 @@ { if (flow != null) { - String name = flow.getTargetName(); + String name = flow.getTargetRef(); Node target = procStruct.getNode(name); if (target == null) throw new InvalidProcessException("Cannot find target for out flow: " + name); @@ -487,8 +502,8 @@ throw new InvalidProcessException("Target does not support in flow: " + target); } - flow.setSourceRef(this); - flow.setTargetRef(target); + flow.setSourceRef(getName()); + flow.setTargetRef(target.getName()); } } } \ No newline at end of file Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/OutputSetImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/OutputSetImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/OutputSetImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -28,7 +28,6 @@ import javax.persistence.Basic; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.OneToOne; @@ -54,7 +53,7 @@ @Basic private int setIndex; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertySupportImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = PropertySupportImpl.class) protected PropertySupport propSupport = new PropertySupportImpl(); int getSetIndex() Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ParallelGatewayImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ParallelGatewayImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ParallelGatewayImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -199,7 +199,7 @@ private TokenImpl getMergedTokens() { - TokenImpl mergedToken = new TokenImpl(getProcessEngine(), null); + TokenImpl mergedToken = new TokenImpl(getProcess(), null); for (Token auxToken : mergeTokens) { log.debug("mergeToken: " + auxToken); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessDefinitionImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessDefinitionImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessDefinitionImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -34,11 +34,11 @@ import javax.management.ObjectName; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.Lob; import javax.persistence.OneToOne; import javax.persistence.Transient; +import org.hibernate.Session; import org.jbpm.api.Constants; import org.jbpm.api.client.ProcessEngine; import org.jbpm.api.model.Assignment; @@ -67,7 +67,7 @@ // provide logging final static Logger log = LoggerFactory.getLogger(ProcessDefinitionImpl.class); - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = ProcessStructureImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = ProcessStructureImpl.class) private ProcessStructure procStruct; @Lob @@ -232,6 +232,11 @@ } @Override + public void initialize(Session session) + { + } + + @Override protected void create(ProcessDefinition procDef) { super.create(procDef); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -31,11 +31,11 @@ import javax.persistence.Entity; import javax.persistence.EnumType; import javax.persistence.Enumerated; -import javax.persistence.FetchType; import javax.persistence.ManyToOne; import javax.persistence.OneToOne; import javax.persistence.Transient; +import org.hibernate.Session; import org.jbpm.api.Constants; import org.jbpm.api.client.ProcessEngine; import org.jbpm.api.model.Assignment; @@ -73,7 +73,7 @@ @ManyToOne(targetEntity = ProcessDefinitionImpl.class) private ProcessDefinition procDef; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = ProcessStructureImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = ProcessStructureImpl.class) private ProcessStructure procStruct; @Transient @@ -276,6 +276,11 @@ } @Override + public void initialize(Session session) + { + } + + @Override protected void create(Process proc) { super.create(proc); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessStructureImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessStructureImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/ProcessStructureImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -32,11 +32,11 @@ import javax.persistence.Basic; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.OneToMany; import javax.persistence.OneToOne; import javax.persistence.Transient; +import org.hibernate.Session; import org.hibernate.annotations.IndexColumn; import org.jbpm.api.Constants; import org.jbpm.api.InvalidProcessException; @@ -74,22 +74,22 @@ private String name; @IndexColumn(name = "nodeIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, mappedBy = "procStruct", targetEntity = NodeImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, mappedBy = "procStruct", targetEntity = NodeImpl.class) private List<Node> nodes = new ArrayList<Node>(); - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertySupportImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = PropertySupportImpl.class) protected PropertySupport propSupport = new PropertySupportImpl(); @IndexColumn(name = "msgIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = MessageImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = MessageImpl.class) private List<Message> messages = new ArrayList<Message>(); @IndexColumn(name = "assignIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = AssignmentImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = AssignmentImpl.class) private List<Assignment> assignments = new ArrayList<Assignment>(); @IndexColumn(name = "groupIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = GroupImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = GroupImpl.class) private List<Group> groups = new ArrayList<Group>(); public ProcessStructureImpl(ProcessEngine engine, String name) @@ -286,6 +286,11 @@ } @Override + public void initialize(Session session) + { + } + + @Override public void create(ProcessDefinition procDef) { super.create(procDef); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/PropertySupportImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/PropertySupportImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/PropertySupportImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -31,7 +31,6 @@ import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.MapKey; @@ -55,7 +54,7 @@ protected Integer id; @MapKey (name = "name") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = PropertyImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = PropertyImpl.class) private Map<String, Property> propmap = new HashMap<String, Property>(); @Override Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/SequenceFlowImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/SequenceFlowImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/SequenceFlowImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -28,14 +28,11 @@ import javax.persistence.Entity; import javax.persistence.EnumType; import javax.persistence.Enumerated; -import javax.persistence.FetchType; import javax.persistence.GeneratedValue; import javax.persistence.Id; -import javax.persistence.ManyToOne; import javax.persistence.OneToOne; import org.jbpm.api.model.Expression; -import org.jbpm.api.model.Node; import org.jbpm.api.model.SequenceFlow; /** @@ -64,25 +61,22 @@ private ConditionType conditionType = ConditionType.None; @Basic - private String targetName; + private String targetRef; - @ManyToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = NodeImpl.class) - private Node sourceRef; + @Basic + private String sourceRef; - @ManyToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = NodeImpl.class) - private Node targetRef; - - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = ExpressionImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = ExpressionImpl.class) private Expression conditionExpression; - public SequenceFlowImpl(String targetName) + public SequenceFlowImpl(String targetRef) { - this.targetName = targetName; + this.targetRef = targetRef; } - public SequenceFlowImpl(String targetName, ConditionType type, Expression expr) + public SequenceFlowImpl(String targetRef, ConditionType type, Expression expr) { - this.targetName = targetName; + this.targetRef = targetRef; this.conditionType = type; this.conditionExpression = (ExpressionImpl)expr; } @@ -112,36 +106,35 @@ this.targetIndex = targetIndex; } - public Node getSourceRef() + @Override + public String getSourceRef() { return sourceRef; } - protected void setSourceRef(Node source) + protected void setSourceRef(String sourceRef) { - this.sourceRef = source; + this.sourceRef = sourceRef; } - public Node getTargetRef() + @Override + public String getTargetRef() { return targetRef; } - protected void setTargetRef(Node target) + protected void setTargetRef(String targetRef) { - this.targetRef = target; + this.targetRef = targetRef; } - public String getTargetName() - { - return targetName; - } - + @Override public ConditionType getConditionType() { return conditionType; } + @Override public Expression getConditionExpression() { return conditionExpression; @@ -149,17 +142,6 @@ public String toString() { - Node sourceRef = getSourceRef(); - Node targetRef = getTargetRef(); - - String srcName = null; - if (sourceRef != null) - srcName = (sourceRef.getName() != null ? sourceRef.getName() : sourceRef.getKey().getCanonicalName()); - - String tarName = null; - if (targetRef != null) - tarName = (targetRef.getName() != null ? targetRef.getName() : targetRef.getKey().getCanonicalName()); - - return "SequenceFlow[" + srcName + "->" + tarName + "]"; + return "SequenceFlow[" + sourceRef + "->" + targetRef + "]"; } } \ No newline at end of file Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/StartEventImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/StartEventImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/StartEventImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -108,7 +108,7 @@ public void setOutFlow(SequenceFlowImpl outFlow) { outFlow.setSourceIndex(outFlows.size()); - outFlow.setSourceRef(this); + outFlow.setSourceRef(getName()); outFlows.add(outFlow); } Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/TaskImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/TaskImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/TaskImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -32,7 +32,6 @@ import javax.persistence.Entity; import javax.persistence.EnumType; import javax.persistence.Enumerated; -import javax.persistence.FetchType; import javax.persistence.OneToMany; import javax.persistence.Transient; @@ -78,15 +77,15 @@ protected TaskType taskType; @IndexColumn(name = "setIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = InputSetImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = InputSetImpl.class) private List<InputSet> inputSets = new ArrayList<InputSet>(); @IndexColumn(name = "setIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = OutputSetImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = OutputSetImpl.class) private List<OutputSet> outputSets = new ArrayList<OutputSet>(); @IndexColumn(name = "exprIndex") - @OneToMany(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = ExpressionImpl.class) + @OneToMany(cascade = { CascadeType.ALL }, targetEntity = ExpressionImpl.class) private List<Expression> ioRules = new ArrayList<Expression>(); public TaskImpl(ProcessStructure procStruct, TaskType taskType, String name) @@ -125,7 +124,7 @@ public void setInFlow(SequenceFlowImpl inFlow) { inFlow.setTargetIndex(inFlows.size()); - inFlow.setTargetRef(this); + inFlow.setTargetRef(getName()); inFlows.add(inFlow); } @@ -140,7 +139,7 @@ public void setOutFlow(SequenceFlowImpl outFlow) { outFlow.setSourceIndex(outFlows.size()); - outFlow.setSourceRef(this); + outFlow.setSourceRef(getName()); outFlows.add(outFlow); } Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/UserTaskImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/UserTaskImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/model/UserTaskImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -29,7 +29,6 @@ import javax.management.ObjectName; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.FetchType; import javax.persistence.OneToOne; import javax.persistence.Transient; @@ -62,10 +61,10 @@ final static Logger log = LoggerFactory.getLogger(UserTaskImpl.class); - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = MessageImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = MessageImpl.class) protected MessageImpl outMessageRef; - @OneToOne(cascade = { CascadeType.ALL }, fetch = FetchType.EAGER, targetEntity = MessageImpl.class) + @OneToOne(cascade = { CascadeType.ALL }, targetEntity = MessageImpl.class) protected MessageImpl inMessageRef; @Transient Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/DelegatingToken.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/DelegatingToken.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/DelegatingToken.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -25,6 +25,7 @@ import org.hibernate.Session; import org.jbpm.api.model.Node; +import org.jbpm.api.model.Process; import org.jbpm.api.model.SequenceFlow; import org.jbpm.api.runtime.ExecutionContext; import org.jbpm.api.runtime.Token; @@ -44,9 +45,10 @@ { this.delegateToken = token; - Node targetRef = token.getSequenceFlow().getTargetRef(); + String targetRef = token.getSequenceFlow().getTargetRef(); + Node targetNode = token.getProcess().getNode(targetRef); ExecutionContext exContext = token.getExecutionContext(); - this.delegateContext = new DelegatingExecutionContext(targetRef, exContext); + this.delegateContext = new DelegatingExecutionContext(targetNode, exContext); } @Override @@ -80,6 +82,12 @@ } @Override + public Process getProcess() + { + return delegateToken.getProcess(); + } + + @Override public void mergeToken(Token token) { delegateToken.mergeToken(token); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RunnableToken.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RunnableToken.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RunnableToken.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -79,7 +79,8 @@ while (continueTokenThread()) { // Get the target node - Node node = token.getSequenceFlow().getTargetRef(); + String targetRef = token.getSequenceFlow().getTargetRef(); + Node node = proc.getNode(targetRef); // Synchronize on the target Node synchronized (node) Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RuntimeContext.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RuntimeContext.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/RuntimeContext.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -57,7 +57,8 @@ public Node getNode() { - return token.getSequenceFlow().getTargetRef(); + String targetRef = token.getSequenceFlow().getTargetRef(); + return token.getProcess().getNode(targetRef); } public Token getToken() Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TokenImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TokenImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TokenImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -26,6 +26,7 @@ import org.hibernate.Session; import org.jboss.util.id.UID; import org.jbpm.api.client.ProcessEngine; +import org.jbpm.api.model.Process; import org.jbpm.api.model.SequenceFlow; import org.jbpm.api.runtime.Attachments; import org.jbpm.api.runtime.BasicExecutionContext; @@ -52,18 +53,18 @@ private SequenceFlow flow; private ExecutionContext context; private TokenStatus status; - private ProcessEngine engine; + private Process process; private Session session; /** * Construct a Token with given {@link Attachments} */ - public TokenImpl(ProcessEngine engine, Attachments att) + public TokenImpl(Process process, Attachments att) { this.context = new BasicExecutionContext(att); this.id = new UID().toString(); this.status = TokenStatus.Created; - this.engine = engine; + this.process = process; } @Override @@ -85,6 +86,12 @@ } @Override + public Process getProcess() + { + return process; + } + + @Override public ExecutionContext getExecutionContext() { return context; @@ -107,6 +114,7 @@ { if (session == null) { + ProcessEngine engine = process.getProcessEngine(); PersistenceService service = engine.getService(PersistenceService.class); session = service.createSession(); } @@ -126,7 +134,7 @@ @Override public MutableToken copyToken() { - return new TokenImpl(engine, context); + return new TokenImpl(process, context); } @Override Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TransactionInterceptor.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TransactionInterceptor.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/runtime/TransactionInterceptor.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -57,7 +57,7 @@ { // Load the node PersistenceService service = getPersistenceService(node.getProcessEngine()); - node = service.loadNode(session, node.getClass(), node.getKey()); + node = service.loadNode(session, node.getClass(), node.getKey(), false); // Call the next interceptor in the chain rtContext.next(); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/ExecutionServiceImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/ExecutionServiceImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/ExecutionServiceImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -114,7 +114,6 @@ InitialFlow(StartEvent start) { super(start.getName()); - setTargetRef(start); } } @@ -122,7 +121,7 @@ boolean startProcessThread = (rtProc == null); // Create initial Token - TokenImpl initialToken = new TokenImpl(getProcessEngine(), att); + TokenImpl initialToken = new TokenImpl(proc, att); InitialFlow initialFlow = new InitialFlow(start); initialToken.setSequenceFlow(initialFlow); Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/HibernatePersistenceServiceImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/HibernatePersistenceServiceImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/HibernatePersistenceServiceImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -43,6 +43,7 @@ import org.jbpm.api.model.ProcessDefinition; import org.jbpm.api.service.PersistenceService; import org.jbpm.api.service.Service; +import org.jbpm.ri.model.AbstractElementImpl; import org.jbpm.ri.model.ProcessDefinitionImpl; import org.jbpm.ri.model.ProcessImpl; import org.slf4j.Logger; @@ -220,7 +221,7 @@ @Override @SuppressWarnings("unchecked") - public <T extends Node> T loadNode(Session session, Class<T> nodeClass, ObjectName nodeID) + public <T extends Node> T loadNode(Session session, Class<T> nodeClass, ObjectName nodeID, boolean fetchEager) { log.debug("START loadNode: " + nodeID); T node = null; @@ -228,7 +229,11 @@ { Integer id = Integer.valueOf(nodeID.getKeyProperty("id")); node = (T)session.load(nodeClass, id); - Hibernate.initialize(node); + if (fetchEager == true) + { + AbstractElementImpl elImpl = (AbstractElementImpl)node; + elImpl.initialize(session); + } } catch (ObjectNotFoundException ex) { Modified: projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/InMemoryPersistenceServiceImpl.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/InMemoryPersistenceServiceImpl.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/main/java/org/jbpm/ri/service/InMemoryPersistenceServiceImpl.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -126,7 +126,7 @@ @Override @SuppressWarnings("unchecked") - public <T extends Node> T loadNode(Session session, Class<T> nodeImpl, ObjectName nodeID) + public <T extends Node> T loadNode(Session session, Class<T> nodeImpl, ObjectName nodeID, boolean fetchEager) { T node = (T)nodes.get(nodeID); if (node == null) Modified: projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/EndEventPersistenceTest.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/EndEventPersistenceTest.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/EndEventPersistenceTest.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -25,14 +25,14 @@ import javax.management.ObjectName; +import org.jbpm.api.model.EndEvent; import org.jbpm.api.model.Message; import org.jbpm.api.model.Signal; -import org.jbpm.api.model.EndEvent; import org.jbpm.api.model.Event.EventDetailType; import org.jbpm.api.model.Signal.SignalType; +import org.jbpm.ri.model.EndEventImpl; import org.jbpm.ri.model.MessageImpl; import org.jbpm.ri.model.SignalImpl; -import org.jbpm.ri.model.EndEventImpl; /** * Test the HibernatePersistenceService for EndEvent Modified: projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/NodePersistenceTest.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/NodePersistenceTest.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/NodePersistenceTest.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -25,7 +25,6 @@ import javax.management.ObjectName; -import org.hibernate.Hibernate; import org.hibernate.Session; import org.hibernate.StaleStateException; import org.hibernate.Transaction; @@ -73,7 +72,7 @@ Session session = service.createSession(); try { - T node = service.loadNode(session, nodeClass, nodeID); + T node = service.loadNode(session, nodeClass, nodeID, true); return node; } finally Modified: projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/TaskPersistenceTest.java =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/TaskPersistenceTest.java 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/test/java/org/jbpm/test/ri/service/persistence/TaskPersistenceTest.java 2008-10-31 16:54:14 UTC (rev 2720) @@ -59,7 +59,7 @@ */ public class TaskPersistenceTest extends NodePersistenceTest { - public void testSimpleTask() throws Exception + public void _testSimpleTask() throws Exception { Task orgNode = new TaskImpl(null, TaskType.None, "Task"); @@ -72,7 +72,7 @@ deleteNode(wasNode); } - public void testTaskProperties() throws Exception + public void _testTaskProperties() throws Exception { TaskImpl orgNode = new TaskImpl(null, TaskType.None, "Task"); orgNode.addProperty("propOne", "valOne"); @@ -89,7 +89,7 @@ deleteNode(wasNode); } - public void testTaskAssignments() throws Exception + public void _testTaskAssignments() throws Exception { TaskImpl orgNode = new TaskImpl(null, TaskType.None, "Task"); orgNode.addAssignment(new AssignmentImpl(AssignTime.Start, new ExpressionImpl("foo"), new PropertyImpl("propFoo", null))); @@ -128,20 +128,19 @@ Task wasB = loadNode(TaskImpl.class, bID); SequenceFlow outFlowA = wasA.getOutFlow(); - assertEquals("TaskB", outFlowA.getTargetName()); - assertEquals("TaskB", outFlowA.getTargetRef().getName()); + assertEquals("TaskB", outFlowA.getTargetRef()); assertEquals(ConditionType.Expression, outFlowA.getConditionType()); assertEquals("expr", outFlowA.getConditionExpression().getExpressionBody()); assertSame(wasA, outFlowA.getSourceRef()); SequenceFlow inFlowB = wasB.getInFlow(); - assertEquals(outFlowA.getTargetName(), inFlowB.getTargetName()); + assertEquals(outFlowA.getTargetRef(), inFlowB.getTargetRef()); deleteNode(wasA); deleteNode(wasB); } - public void testExecHandler() throws Exception + public void _testExecHandler() throws Exception { class ExecHandler implements ExecutionHandler { @@ -178,7 +177,7 @@ deleteNode(wasNode); } - public void testSignalHandler() throws Exception + public void _testSignalHandler() throws Exception { class SigHandler implements SignalHandler { @@ -220,7 +219,7 @@ deleteNode(wasNode); } - public void testFlowHandler() throws Exception + public void _testFlowHandler() throws Exception { class FlowHandlerImpl implements FlowHandler { @@ -257,7 +256,7 @@ deleteNode(wasNode); } - public void testInputSet() throws Exception + public void _testInputSet() throws Exception { TaskImpl orgNode = new TaskImpl(null, TaskType.None, "Task"); @@ -283,7 +282,7 @@ deleteNode(wasNode); } - public void testOutputSet() throws Exception + public void _testOutputSet() throws Exception { TaskImpl orgNode = new TaskImpl(null, TaskType.None, "Task"); @@ -309,7 +308,7 @@ deleteNode(wasNode); } - public void testIORules() throws Exception + public void _testIORules() throws Exception { TaskImpl orgNode = new TaskImpl(null, TaskType.None, "Task"); orgNode.addIORule(new ExpressionImpl("ioOne")); Modified: projects/spec/branches/tdiesler/modules/ri/src/test/resources/log4j.xml =================================================================== --- projects/spec/branches/tdiesler/modules/ri/src/test/resources/log4j.xml 2008-10-31 16:52:56 UTC (rev 2719) +++ projects/spec/branches/tdiesler/modules/ri/src/test/resources/log4j.xml 2008-10-31 16:54:14 UTC (rev 2720) @@ -33,9 +33,6 @@ <!-- ================ --> <category name="org.hibernate"> - <priority value="INFO" /> - </category> - <category name="org.hibernate.persister"> <priority value="DEBUG" /> </category>