Package de.scoopgmbh.copper.test.backchannel

Examples of de.scoopgmbh.copper.test.backchannel.WorkflowResult


      for (int i=0; i<10; i++) {
        callFoo();
        assertNotNull(this.getCreationTS());
      }
      auditTrail.asynchLog(0, new Date(), "unittest", "-", this.getId(), null, null, "finished", null);
      backChannelQueue.enqueue(new WorkflowResult(getData(), null));
    }
    catch(Exception e) {
      logger.error("execution failed",e);
      backChannelQueue.enqueue(new WorkflowResult(null, e));
    }
//    finally {
//      System.out.println("xxx");
//    }
  }
View Full Code Here


      }
      catch(RuntimeException e) {
        logger.error("just for testing - runtime exception caught",e);
        throw e;
      }
      backChannelQueue.enqueue(new WorkflowResult(null, null));
    }
    catch(Exception e) {
      logger.error("execution failed",e);
      backChannelQueue.enqueue(new WorkflowResult(null, e));
    }
  }
View Full Code Here

      }

      callFooWithWaitHook();
     
      auditTrail.asynchLog(0, new Date(), "unittest", "-", this.getId(), null, null, "finished", "TEXT");
      backChannelQueue.enqueue(new WorkflowResult(getData(), null));
    }
    catch(Exception e) {
      logger.error("execution failed",e);
      backChannelQueue.enqueue(new WorkflowResult(null, e));
    }
  }
View Full Code Here

      assertNotNull(r.getResponse());
      assertNull(r.getException());
      assertFalse(r.isTimeout());
      assertEquals("54321", r.getResponse());

      backChannelQueue.enqueue(new WorkflowResult(null, null));
    }
    catch(Exception e) {
      e.printStackTrace();
      backChannelQueue.enqueue(new WorkflowResult(null, e));
    }
  }
View Full Code Here

    try {
      for (int i=0; i<3; i++) {
        callFoo();
        assertNotNull(this.getCreationTS());
      }
      backChannelQueue.enqueue(new WorkflowResult(getData(), null));
      backChannelQueue = null;
      throw new RuntimeException("test exception to abort execution!!!");
    }
    catch(RuntimeException e) {
      logger.error("execution failed",e);
      if (backChannelQueue != null) backChannelQueue.enqueue(new WorkflowResult(null, e));
      throw e;
    }
  }
View Full Code Here

      assertNotNull(r.getResponse());
      assertNull(r.getException());
      assertFalse(r.isTimeout());
      assertEquals("54321", r.getResponse());
     
      backChannelQueue.enqueue(new WorkflowResult(null, null));
    }
    catch(Exception e) {
      e.printStackTrace();
      backChannelQueue.enqueue(new WorkflowResult(null, e));
    }
  }
View Full Code Here

   
    assertEquals(EngineState.STARTED,engine.getEngineState());
   
    try {
      engine.run("de.scoopgmbh.copper.test.tranzient.simple.SimpleTestParentWorkflow","testData");
      WorkflowResult r = backChannelQueue.dequeue(2000, TimeUnit.MILLISECONDS);
      assertNotNull(r);
    }
    finally {
      context.close();
    }
View Full Code Here

TOP

Related Classes of de.scoopgmbh.copper.test.backchannel.WorkflowResult

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.