Examples of nexj.core.meta.workflow.Concurrent.addStep()

Class nexj.core.meta.workflow.Concurrent

Examples of nexj.core.meta.workflow.Concurrent.addStep()

nexj.core.meta.workflow.Concurrent.addStep()

               Timeout timeout = new Timeout();


               timeout.setActivity(activity);
               timeout.setValue(m_helper.parse(XMLUtil.getReqStringAttr(eventElement, "value"),
                  false, activity.getFlow().getPosMap(), null, m_metadata.getGlobalEnvironment()));
               activity.addStep(timeout);


               Wait wait = new Wait(timeout);


               timeout.setNext(wait);
               activity.addStep(wait);

View Full Code Here

               activity.addStep(timeout);


               Wait wait = new Wait(timeout);


               timeout.setNext(wait);
               activity.addStep(wait);


               m_bTimer = true;
            }
            else if (sElement.equals("ClassEvent"))
            {

View Full Code Here

            else if (sElement.equals("ClassEvent"))
            {
               AutoCompletion completion = new AutoCompletion(assignment);


               loadWorkflowHandler(eventElement, completion, activity.getFlow());
               activity.addStep(completion);
            }
            else if (sElement.equals("ManualEvent"))
            {
               Object condition = m_helper.parse(XMLUtil.getStringAttr(eventElement, "condition"),
                  false, assignment.getActivity().getFlow().getPosMap(),

View Full Code Here


               if (assignment.getManualCompletion() == null)
               {
                  ManualCompletion completion = new ManualCompletion(assignment);


                  activity.addStep(completion);
               }
               else
               {
                  activity = null;
               }

View Full Code Here

               assignment.setSemaphore(true);


               Semaphore semaphore = new Semaphore(assignment.getName() + ":Semaphore", assignment);


               semaphore.setActivity(activity);
               activity.addStep(semaphore);


               Block block = new Block();


               block.setActivity(branch);
               branch.addStep(block);

View Full Code Here

               }


               Script script = new Script();


               script.setBody(Pair.list(Pair.list(Symbol.SET, var.getSymbol(), code)));
               activity.addStep(script);
               fork.addConcurrent(activity);
            }


            if (branch == null)
            {

View Full Code Here

      {
         Activity activity = fork.getConcurrent(0);


         if (activity.getStep(0) instanceof Timeout)
         {
            activity.addStep(new Completion(assignment));
         }


         if (decision.getBranchCount() > 1)
         {
            for (int i = 0; i != activity.getStepCount(); ++i)

View Full Code Here

TOP

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.