Package org.jbpm.context.exe

Examples of org.jbpm.context.exe.ContextInstance

39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
  String msg;

  public void execute(ExecutionContext executionContext) throws Exception {
    TaskMgmtDefinition taskMgmtDefinition = executionContext.getProcessDefinition().getTaskMgmtDefinition();
    TaskMgmtInstance taskMgmtInstance = executionContext.getTaskMgmtInstance();
    ContextInstance contextInstance = executionContext.getContextInstance();
   
    Swimlane shipperSwimlane = taskMgmtDefinition.getSwimlane("shipper");
    SwimlaneInstance shipperSwimlaneInstance = taskMgmtInstance.getInitializedSwimlaneInstance(executionContext, shipperSwimlane);

    String actorId = shipperSwimlaneInstance.getActorId();
   
    String displayMsg = replace(msg, "${"+swimlaneName+"}", actorId);
    displayMsg = replace(displayMsg, "${item}", (String)contextInstance.getVariable("item"));
    displayMsg = replace(displayMsg, "${address}", (String)contextInstance.getVariable("address"));
   
    log.info("###############################################");
    log.info("### "+displayMsg);
    log.info("###############################################");
   
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
    );
    jbpmContext.deployProcessDefinition(superDefinition);
    newTransaction();
   
    ProcessInstance superInstance = jbpmContext.newProcessInstanceForUpdate("super");
    ContextInstance superContext = superInstance.getContextInstance();
    superContext.setVariable("a", "value a");
    superContext.setVariable("b", "value b");
    superInstance.signal();
   
    commitAndCloseSession();
    try {
      SchedulerThread schedulerThread = new SchedulerThread(jbpmConfiguration);
      schedulerThread.executeTimers();
    } finally {
      beginSessionTransaction();
    }

    superInstance = jbpmContext.loadProcessInstance(superInstance.getId());
    assertEquals("async", superInstance.getRootToken().getNode().getName());
   
    commitAndCloseSession();
    try {
      CommandExecutorThread commandExecutorThread = new CommandExecutorThread(jbpmConfiguration);
      commandExecutorThread.executeCommand();
    } finally {
      beginSessionTransaction();
    }

    List taskInstances = taskMgmtSession.findTaskInstances("victim");
    assertEquals(1, taskInstances.size());
    TaskInstance taskInstance = (TaskInstance) taskInstances.get(0);
    taskInstance.setVariable("a", "value a updated");
    taskInstance.setVariable("b", "value b updated");
    taskInstance.end();
   
    jbpmContext.save(taskInstance);
    long taskInstanceId = taskInstance.getId();
    long tokenId = taskInstance.getToken().getId();
    newTransaction();
   
    taskInstance = jbpmContext.loadTaskInstance(taskInstanceId);
    assertEquals("value a updated", taskInstance.getVariable("a"));
    assertEquals("value b updated", taskInstance.getVariable("b"));
   
    Token token = jbpmContext.loadToken(tokenId);
    ContextInstance subContextInstance = token.getProcessInstance().getContextInstance();
    assertEquals("value a", subContextInstance.getVariable("a"));
    assertEquals("value b updated", subContextInstance.getVariable("b"));
  }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
46
                && (executionContext.getTaskInstance().hasVariableLocally(name))
              ) {
      value = executionContext.getTaskInstance().getVariable(name);

    } else {
      ContextInstance contextInstance = executionContext.getContextInstance();
      Token token = executionContext.getToken();
      value = contextInstance.getVariable(name, token);
    }

    return value;
  }
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
    assertEquals("super", superProcessDefinition.getName());
  }
 
  public void testProcessInstanceModuleInstances() {
    ProcessInstance processInstance = new ProcessInstance();
    processInstance.addInstance(new ContextInstance());
    processInstance.addInstance(new TaskMgmtInstance());
  
    processInstance = saveAndReload(processInstance);

    assertNotNull(processInstance.getInstances());
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
83
84
  }
 
  public static class EnterNodeS implements ActionHandler {
    private static final long serialVersionUID = 1L;
    public void execute(ExecutionContext executionContext) throws Exception {
      ContextInstance contextInstance = executionContext.getContextInstance();
      Integer invocationCount = (Integer) contextInstance.getVariable("invocationCount");
      if (invocationCount==null) {
        contextInstance.setVariable("invocationCount", new Integer(1));
      } else {
        contextInstance.setVariable("invocationCount", new Integer(invocationCount.intValue()+1));
      }
    }
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
108
109
110
     * @param message
     */
    private void setAllOnEsbMessage(final boolean gblPrcScope, final ExecutionContext executionContext, Message message)
    {
        Token token = executionContext.getToken();
        ContextInstance ctxInstance = token.getProcessInstance().getContextInstance();
        log.debug("The user has not mapped anything (jbpmToEsbVars is null) " +
                  "so add all the variables using their jBPM name");
        Map map = (gblPrcScope) ? ctxInstance.getVariables() : ctxInstance.getVariables(token);
        if (null != map) {
            for (Iterator iter = map.entrySet().iterator(); iter.hasNext();){
                Map.Entry jBPMVariable = (Map.Entry) iter.next();
                message.getBody().add(jBPMVariable.getKey().toString(), jBPMVariable.getValue());
            }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
        }
        if (mapping.getEsb()==null || "".equals(mapping.getEsb())) {
            mapping.setEsb(mapping.getBpm());
        }
        Token token = executionContext.getToken();
        ContextInstance ctxInstance = token.getProcessInstance().getContextInstance();
        //Each mapping can override the global setting
        boolean isPrcScope = (null == mapping.getIsProcessScope()) ? gblPrcScope : mapping.getIsProcessScope();
        //By default assume the object is part of the jBPM variableMap
        Object object = getObjectFromJBpmVariableMap(isPrcScope, mapping.getBpm(), ctxInstance, token);
        //if that fails then try to get it from the ExecutionContext
View Full Code Here
334
335
336
337
338
339
340
341
342
343
344
345
    {
        AssertArgument.isNotNull(executionContext, "executionContext");
        AssertArgument.isNotNull(esbMessage, "esbMessage");

        final Token token = executionContext.getToken();
        final ContextInstance ctxInstance = token.getProcessInstance().getContextInstance();
        final Map jbpmMap = (gblPrcScope) ? ctxInstance.getVariables() : ctxInstance.getVariables(token);

        if (jbpmMap == null)
        {
            return esbMessage;
        }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
147
           
            if (token.isLocked()) {
                throw new CallbackException("Token id " + tokenId + " from process instance " + processInstanceId + " is already locked, another thread is active") ;
            }
           
            final ContextInstance contextInstance = instance.getContextInstance() ;
            final long currentProcessNodeVersion = Long.parseLong(String.valueOf(contextInstance.getVariableLocally(counterName, token)));
            if (isDebugEnabled) logger.debug("ProcessNodeVersion=" + currentProcessNodeVersion);
            if (processNodeVersion!=currentProcessNodeVersion) {
                throw new CallbackException("The current processNodeVersion (id=" + currentProcessNodeVersion + ") is not the expected version (version=" + processNodeVersion + ").");
            }
           
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
//          Set the replyTo to the JBpmCallback Service
            EPR faultTo = createFaultTo(esbToBpmVarsXml, globalProcessScope, executionContext);
            message.getHeader().getCall().setFaultTo(faultTo);
        }
       
        final ContextInstance contextInstance = executionContext.getContextInstance() ;
       
        if (isReplyToOrFaultToSet(contextInstance))
        {
            setRelatesToMessageId(contextInstance, message);
        }
       
        //Sending the message on its way
        if (logger.isDebugEnabled()) logger.debug("Created ESB message=" + message);
       
        if (replyToOriginator != null) {
            final EPR epr ;
            final Object replyToEPR = contextInstance.getVariable(Constants.REPLY_TO);
            final Object faultToEPR = contextInstance.getVariable(Constants.FAULT_TO);

            if (Constants.EPR_FAULT.equals(replyToOriginator) && (faultToEPR != null)) {
                epr = EPRHelper.fromXMLString(faultToEPR.toString()) ;
            } else if (replyToEPR != null) {
                epr = EPRHelper.fromXMLString(replyToEPR.toString()) ;
View Full Code Here
TOP

Related Classes of org.jbpm.context.exe.ContextInstance

  • com.jboss.jbossnetwork.product.jbpm.handlers.SetProcessStatusActionHandler
  • com.pajb.ire.engine.AgendaGroupActionHandler
  • de.mhus.lib.bpm.jbpm3.JBpmInstance
  • it.eng.spagobi.engines.dossier.actions.DossierDownloadAction
  • it.eng.spagobi.engines.dossier.automatictasks.GenerateFinalDocumentAction
  • it.eng.spagobi.engines.dossier.automatictasks.ProcessOOTemplateAction
  • it.eng.spagobi.engines.dossier.modules.DossierCollaborationModule
  • it.eng.spagobi.workflow.services.CompleteOrRejectActivityModule
  • it.eng.spagobi.workflow.services.WorkListModule
  • org.drools.jpdl.instance.node.JpdlNodeInstance$JpdlExecutionContext
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.