Package de.danet.an.workflow.api

Examples of de.danet.an.workflow.api.Process.key()

194
195
196
197
198
199
200
201
202
203
204
  assertTrue (c1.size() == 2);
  boolean foundA = false; 
  boolean foundB = false;
  for (Iterator i = c1.iterator(); i.hasNext();) {
      Process p = (Process)i.next();
      if (p.key().equals (proc1a.key())) {
    foundA = true;
      }
      if (p.key().equals (proc1b.key())) {
    foundB = true;
      }
View Full Code Here
197
198
199
200
201
202
203
204
205
206
207
  for (Iterator i = c1.iterator(); i.hasNext();) {
      Process p = (Process)i.next();
      if (p.key().equals (proc1a.key())) {
    foundA = true;
      }
      if (p.key().equals (proc1b.key())) {
    foundB = true;
      }
  }
  assertTrue (foundA && foundB);
  Thread.sleep (2000);
View Full Code Here
549
550
551
552
553
554
555
556
557
558
559
    public void removeClosedProcessjut1() throws Exception {
  WfRequester req = new DefaultRequester(workflowService);
  ProcessDirectory procDir = processDirectory();
  // create the process
  Process process = (Process)(createProcess("ut-process", "jut5", req));
  String processKey = process.key();
  assertTrue(process.state().equals("open.not_running.not_started"));
  // start the process
  process.start();
  assertTrue(process.state().startsWith("open.running"));
  Thread.sleep (1000);
View Full Code Here
748
749
750
751
752
753
754
755
756
757
758
        ProcessDefinition procdef = proc.processDefinition();
        try {
            ObserverRegistry obs = getObserverRegistry();
            obs.subscribe
                (observer, procdef.packageId(),
                 procdef.processId(), proc.key(),
                 getResourceReference().getBaseUrl());
        } catch (SQLException e) {
            FaultUtils.setFault(respMsg, e);
           
            return;
View Full Code Here
803
804
805
806
807
808
809
810
811
812
813
        ProcessDefinition procdef = proc.processDefinition();
        try {
            ObserverRegistry obs = getObserverRegistry();
            obs.unsubscribe(observer, procdef.packageId(), procdef.processId(),
                    proc.key());
        } catch (SQLException e) {
            FaultUtils.setFault(respMsg, e);
           
            return;
        }
View Full Code Here
245
246
247
248
249
250
251
252
253
254
255
        this.resource = AbstractResponseGenerator.RESOURCE_ACTIVITY;
        Process process = (Process)activity.container();
        ProcessDefinition procDef = process.processDefinition();
        this.packageId = procDef.packageId();
        this.processId = procDef.processId();
        this.processKey = process.key();
        this.activityKey = activity.key();
    }

    /**
     * Constructs a new object.
View Full Code Here
650
651
652
653
654
655
656
657
658
659
660
        if (observer != null) {
            try {
                ProcessDefinition procdef = proc.processDefinition();
                ObserverRegistry obs = getObserverRegistry();
                obs.subscribe(observer, procdef.packageId(), procdef
                        .processId(), proc.key(), getResourceReference()
                        .getBaseUrl());
            } catch (SQLException e) {
                FaultUtils.setFault(respMsg, e);

                return;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.