Examples of WfRequester

de.danet.an.workflow.omgcore.WfRequester
WfRequester is the interface that has a direct concern with the execution and results of a workflow process. It represents the request for some work to be done. Its performer, a {@link de.danet.an.workflow.omgcore.WfProcess WfProcess} isexpected to handle its request and communicate significant status changes; in particular to inform the requester when it has completed performing the request work.
The support of WfRequesters in a workflow engine implementation is complicated because the {@link WfAuditHandler#receiveEvent receiveEvent} methodreverses the client server relationship and because an object from the application space must be stored by the server.
Implementations of WfRequester are therefore subject to the following restrictions:
- The implementation must implement {@link java.io.Serializable java.io.Serializable}. Make sure not to use any attributes that are not serializable.
- In order for deserialization to work, the implementation's class file must be in the classpath of the application server.
- The implementation must provide proper {@link Object#equals equals} and {@link Object#hashCode hashCode}methods.
Most applications will simply use the requester provided as {@link de.danet.an.workflow.api.DefaultRequester DefaultRequester}.
org.enhydra.shark.api.client.wfmodel.WfRequester

Examples of de.danet.an.workflow.omgcore.WfRequester


    /**
     * Lookup by data.
     */
    public void lookupByData () throws Exception {
  WfRequester req = new DefaultRequester(workflowService());


  // Remove all old processes
  ProcessDefinitionDirectory procDefDir 
      = workflowService().processDefinitionDirectory ();
  ProcessDirectory procDir = workflowService().processDirectory ();

View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfRequester

  }
  pdd.importProcessDefinitions(sb.toString());
    }


    public void runTest () throws Exception {
        WfRequester req = new DefaultRequester (workflowService());
  WfProcess process = createProcess
      ("testByAudit2", "testByAudit_emptySeq_na", req);
  assertTrue(process!=null);
  process.start ();
  assertTrue (stateReached (process, "closed"));

View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfRequester

    /**
     * Returns the requester for this process. Method of the omg interface.
     * @return requester for this process. 
     */
    public WfRequester requester() {
  WfRequester req = getPaRequester();
        if (req instanceof SubProcRequester) {
            try {
                return lookupActivityLocal
                    (((SubProcRequester)req).requestingActivity()).toActivity();
            } catch (InvalidKeyException e) {

View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfRequester

    /**
     * Handles a terminated audit event.
     * @param event the event.
     */
    protected void handleTerminatedEvent (WfStateAuditEvent event) {
  WfRequester req = unresolvedRequester();
  if ((req instanceof SubProcRequester)
      && (((SubProcRequester)req).execution() 
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {

View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfRequester

    /**
     * Handles a aborting audit event.
     * @param event the event.
     */
    protected void handleAbortedEvent (WfStateAuditEvent event) {
  WfRequester req = unresolvedRequester();
  if ((req instanceof SubProcRequester)
      && (((SubProcRequester)req).execution() 
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {

View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfRequester

    /**
     * Handles a completed audit event.
     * @param event the event.
     */
    protected void handleCompletedEvent (WfStateAuditEvent event) {
  WfRequester req = unresolvedRequester();
  if ((req instanceof SubProcRequester)
      && (((SubProcRequester)req).execution() 
    == SubFlowImplementation.SYNCHR)) {
      String key = ((SubProcRequester)req).requestingActivity();
      try {

View Full Code Here

Examples of de.danet.an.workflow.omgcore.WfRequester

      try {
    ExtProcessLocal process = (ExtProcessLocal)act.containerLocal();
    ProcessDefinitionDirectoryLocal pdd 
        = (ProcessDefinitionDirectoryLocal)
        process.processDefinitionDirectoryLocal ();
    WfRequester req = new SubProcRequester (act, execMode);
    ProcessData pd = new DefaultProcessData 
        (parameterMap (process, act, pdd));    
    WfProcessLocal p 
                    = pdd.createProcessLocal (packageId(), processId(), req);
    p.setProcessContext(pd);

View Full Code Here

Examples of org.enhydra.shark.api.client.wfmodel.WfRequester

                WMSessionHandle sessionHandle = sc.getSessionHandle();
                WMEntity ent = admin.getActivityDefinitionInfo(sessionHandle, process.key(), activity.key());
                ass.setActivityDefId(ent.getId());
                ass.setProcessRequesterId(getUserByProcessIdAndActivityDefId(ass.getProcessDefId(), ass.getProcessId(), WorkflowUtil.ACTIVITY_DEF_ID_RUN_PROCESS));


                WfRequester requester = process.requester();
                if (requester != null) {
                    boolean isSubflow = (requester instanceof WfActivity);
                    if (isSubflow) {
                        WfActivity act = (WfActivity) requester;
                        ass.setSubflow(true);

View Full Code Here

Examples of org.enhydra.shark.api.client.wfmodel.WfRequester

                ass.setProcessDefId(manager.name());
                WorkflowActivity wfActivity = getRunningActivityInfo(activity.key());
                ass.setDateCreated(wfActivity.getCreatedTime());
                ass.setDueDate(wfActivity.getDue());


                WfRequester requester = process.requester();
                if (requester != null) {
                    boolean isSubflow = (requester instanceof WfActivity);
                    if (isSubflow) {
                        WfActivity act = (WfActivity) requester;
                        ass.setSubflow(true);

View Full Code Here

Examples of org.enhydra.shark.api.client.wfmodel.WfRequester


                    //process activity name variable
                    ass.setActivityName(WorkflowUtil.processVariable(ass.getActivityName(), null, ass));
                }


                WfRequester requester = process.requester();
                if (requester != null) {
                    boolean isSubflow = (requester instanceof WfActivity);
                    if (isSubflow) {
                        WfActivity act = (WfActivity) requester;
                        ass.setSubflow(true);

View Full Code Here

0 1 2 3 4 5

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.