Package de.scoopgmbh.copper.tranzient

Examples of de.scoopgmbh.copper.tranzient.TransientProcessorPool


  @Test
  public void testWorkflow() throws Exception {
    ConfigurableApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"transient-engine-application-context.xml", "SimpleTransientEngineTest-application-context.xml"});
    TransientScottyEngine engine = (TransientScottyEngine) context.getBean("transientEngine");
    TransientProcessorPool processorPool = (TransientProcessorPool) context.getBean("T_ProcessorPool_DEFAULT");
    assertEquals(EngineState.STARTED,engine.getEngineState());
   
    try {
      final BlockingResponseReceiver<Integer> brr = new BlockingResponseReceiver<Integer>();
      Thread.sleep(10);
      assertFalse(brr.isResponseReceived());
     
      processorPool.suspend();
     
      engine.run("de.scoopgmbh.copper.test.tranzient.simple.NopTransientWorkflow", brr);

      brr.wait4response(100L);
     
      assertFalse(brr.isResponseReceived());

      processorPool.resume();
     
      brr.wait4response(100L);
     
      assertEquals(1,brr.getResponse().intValue());
    }
View Full Code Here

TOP

Related Classes of de.scoopgmbh.copper.tranzient.TransientProcessorPool

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.