Examples of org.apache.lenya.workflow.SynchronizedWorkflowInstances

org.apache.lenya.workflow.SynchronizedWorkflowInstances
Synchronized workflow instances.

A set of workflow instances with the same workflow schema can be synchronized. If a transition in this schema is marked as synchronized, it can only be invoked on all instances in the set at the same time.

When a workflow event is invoked on a set of synchronized workflow instances, the transition is invoked only if
- all instances are in the source state of the transition, and
- all conditions of the transition are complied for all instances.
Then the transition is invoked for all instances in the set.

A common usecase of this concept is the simultaneous publishing of a set of documents (all language versions of a document, a section, ...).

        WorkflowFactory factory = WorkflowFactory.newInstance();
        if (factory.hasWorkflow(document)) {
            try {
                Situation situation = getSituation();


                SynchronizedWorkflowInstances instance;
                try {
                    instance = factory.buildSynchronizedInstance(document);
                } catch (WorkflowException e) {
                    throw new ExecutionException(e);
                }

View Full Code Here

        if (factory.hasWorkflow(document)) {
            try {
                String userId = getParameters().getParameter(PARAMETER_USER_ID);
                String machineIp = getParameters().getParameter(PARAMETER_IP_ADDRESS);


                SynchronizedWorkflowInstances instance;
                try {
                    instance = factory.buildSynchronizedInstance(document);
                } catch (WorkflowException e) {
                    throw new ExecutionException(e);
                }
                Situation situation = factory.buildSituation(getRoleIDs(), userId, machineIp);


                Event event = getExecutableEvent(instance, situation);


                assert event != null;


                if (log.isDebugEnabled()) {
                    log.debug("Invoking event [" + event.getName() + "]");
                }
                instance.invoke(situation, event);
                if (log.isDebugEnabled()) {
                    log.debug("Invoking transition completed.");
                }
            } catch (Exception e) {
                throw new ExecutionException(e);

View Full Code Here


            if (getLogger().isDebugEnabled()) {
                getLogger().debug("    Invoking workflow event");
            }


            SynchronizedWorkflowInstances instance = factory.buildSynchronizedInstance(document);
            Situation situation = WorkflowHelper.buildSituation(objectModel);
            Event[] events = instance.getExecutableEvents(situation);
            Event event = null;


            for (int i = 0; i < events.length; i++) {
                if (events[i].getName().equals(eventName)) {
                    event = events[i];
                }
            }


            assert event != null;
            instance.invoke(situation, event);
        } else {
            if (getLogger().isDebugEnabled()) {
                getLogger().debug("    Document has no workflow.");
            }
        }

View Full Code Here


          Document document = builder.buildDocument(publication, url);
          WorkflowFactory factory = WorkflowFactory.newInstance();


          if (factory.hasWorkflow(document)) {
            SynchronizedWorkflowInstances instance =
              factory.buildSynchronizedInstance(document);


            authorized = false;


            Situation situation = WorkflowHelper.buildSituation(request);
            Event[] events = instance.getExecutableEvents(situation);
            int i = 0;


            while (!authorized && (i < events.length)) {
              if (events[i].getName().equals(event)) {
                authorized = true;

View Full Code Here

  public void invokeTransition() throws ExecutionException {
    if (doTransition) {


      try {
        WorkflowFactory factory = WorkflowFactory.newInstance();
        SynchronizedWorkflowInstances instance =
          factory.buildSynchronizedInstance(document);
        Situation situation =
          factory.buildSituation(getRoleIDs(), getUserId(), getMachineIp());


        Event event = null;
        Event[] events = instance.getExecutableEvents(situation);


        log.debug("Resolved executable events.");
        
        for (int i = 0; i < events.length; i++) {
          if (events[i].getName().equals(getEventName())) {
            event = events[i];
          }
        }


        assert event != null;
        
        log.debug("Invoking transition.");
        instance.invoke(situation, event);
        log.debug("Invoking transition completed.");


      } catch (Exception e) {
        throw new ExecutionException(e);
      }

View Full Code Here

        WorkflowFactory factory = WorkflowFactory.newInstance();
        if (factory.hasWorkflow(document)) {
            try {
                Situation situation = getSituation();


                SynchronizedWorkflowInstances instance;
                try {
                    instance = factory.buildSynchronizedInstance(document);
                } catch (WorkflowException e) {
                    throw new ExecutionException(e);
                }

View Full Code Here

        if (factory.hasWorkflow(document)) {
            try {
                String userId = getParameters().getParameter(PARAMETER_USER_ID);
                String machineIp = getParameters().getParameter(PARAMETER_IP_ADDRESS);


                SynchronizedWorkflowInstances instance;
                try {
                    instance = factory.buildSynchronizedInstance(document);
                } catch (WorkflowException e) {
                    throw new ExecutionException(e);
                }
                Situation situation = factory.buildSituation(getRoleIDs(), userId, machineIp);


                Event event = getExecutableEvent(instance, situation);


                assert event != null;


                if (log.isDebugEnabled()) {
                    log.debug("Invoking event [" + event.getName() + "]");
                }
                instance.invoke(situation, event);
                if (log.isDebugEnabled()) {
                    log.debug("Invoking transition completed.");
                }
            } catch (Exception e) {
                throw new ExecutionException(e);

View Full Code Here


            if (getLogger().isDebugEnabled()) {
                getLogger().debug("    Invoking workflow event");
            }


            SynchronizedWorkflowInstances instance = factory.buildSynchronizedInstance(document);
            Situation situation = factory.buildSituation(objectModel);
            Event[] events = instance.getExecutableEvents(situation);
            Event event = null;


            for (int i = 0; i < events.length; i++) {
                if (events[i].getName().equals(eventName)) {
                    event = events[i];
                }
            }


            assert event != null;
            instance.invoke(situation, event);
        } else {
            if (getLogger().isDebugEnabled()) {
                getLogger().debug("    Document has no workflow.");
            }
        }

View Full Code Here

        WorkflowFactory factory = WorkflowFactory.newInstance();
        if (factory.hasWorkflow(document)) {
            try {
                String userId = getParameters().getParameter(PARAMETER_USER_ID);
                String machineIp = getParameters().getParameter(PARAMETER_IP_ADDRESS);
                SynchronizedWorkflowInstances instance;
                try {
                    instance = factory.buildSynchronizedInstance(document);
                } catch (WorkflowException e) {
                    throw new ExecutionException(e);
                }

View Full Code Here

        if (factory.hasWorkflow(document)) {
            try {
                String userId = getParameters().getParameter(PARAMETER_USER_ID);
                String machineIp = getParameters().getParameter(PARAMETER_IP_ADDRESS);


                SynchronizedWorkflowInstances instance;
                try {
                    instance = factory.buildSynchronizedInstance(document);
                } catch (WorkflowException e) {
                    throw new ExecutionException(e);
                }
                Situation situation = factory.buildSituation(getRoleIDs(), userId, machineIp);


                Event event = getExecutableEvent(instance, situation);


                assert event != null;


                if (log.isDebugEnabled()) {
                    log.debug("Invoking event [" + event.getName() + "]");
                }
                instance.invoke(situation, event);
                if (log.isDebugEnabled()) {
                    log.debug("Invoking transition completed.");
                }
            } catch (Exception e) {
                throw new ExecutionException(e);

View Full Code Here

0 1 2

TOP

Related Classes of org.apache.lenya.workflow.SynchronizedWorkflowInstances

org.apache.lenya.cms.ac.workflow.WorkflowAuthorizer

org.apache.lenya.cms.cocoon.acting.WorkflowInvokerAction

org.apache.lenya.cms.publication.task.PublicationTask

org.apache.lenya.cms.task.WorkflowInvoker

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.