Package org.apache.uima.adapter.jms.client

Examples of org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngine_impl.stop()

1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
      }
    }
    // Send another CPC
    eeUimaEngine.collectionProcessingComplete();

    eeUimaEngine.stop();

    // Reset inactivity to original value or remove if it was not set
    if (sessionTimeoutOverride != null) {
      System.setProperty("SessionTimeoutOverride", sessionTimeoutOverride);
    } else {
View Full Code Here
1506
1507
1508
1509
1510
1511
1512
1513
1514
1515
1516
      return;
    } catch (Exception e) {
      fail("Invalid Exception Thrown. Expected:" + ResourceInitializationException.class
              + " Received:" + e.getClass());
    } finally {
      eeUimaEngine.stop();
    }
    fail("Expected" + ResourceInitializationException.class);
  }

  /**
 
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
          errorCount++;
        } finally {
          cas.release();
        }
      }
      uimaAsEngine.stop();
      System.clearProperty("BrokerURL");
      broker.stop();
      synchronized(this) {
        wait(3000);   // allow broker some time to stop 
      }
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
          errorCount++;
        } finally {
          cas.release();
        }
      }
      uimaAsEngine.stop();
      System.clearProperty("BrokerURL");
      broker.stop();
      synchronized(this) {
        wait(3000);   // allow broker some time to stop 
      }
View Full Code Here
330
331
332
333
334
335
336
337
338
339
340
        } finally {
          cas.release();
        }
      }
     
      uimaAsEngine.stop();
      //  expecting 5 failures due to broker missing
      if ( errorCount != 5 ) {
        fail("Expected 5 failures due to broker down, instead received:"+errorCount+" failures");
      }
      System.clearProperty("BrokerURL");
View Full Code Here
391
392
393
394
395
396
397
398
399
400
401
        } finally {
          cas.release();
        }
      }
     
      uimaAsEngine.stop();
      broker.stop();

      //  expecting 5 failures due to broker missing
      if ( errorCount != 5 ) {
        fail("Expected 5 failures due to broker down, instead received:"+errorCount+" failures");
View Full Code Here
454
455
456
457
458
459
460
461
462
463
464
              } finally {
                cas.release();
              }
            }
            System.out.println("Thread:"+Thread.currentThread().getId()+" Completed run()");
            uimaAsEngine.stop();
          } catch( Exception e) {
            e.printStackTrace();
            return;
          }
        }
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
        cas.setDocumentText("Some Text");
        System.out.println("UIMA AS Client Sending CAS#" + (i + 1) + " Request to a Service");
        uimaAsEngine.sendCAS(cas);
      }
     
      uimaAsEngine.stop();
      System.clearProperty("BrokerURL");
  }
 
  public void testAsyncClientRecoveryFromBrokerStopAndRestart() throws Exception  {
    System.out.println("-------------- testAsyncClientRecoveryFromBrokerStopAndRestart -------------");
View Full Code Here
566
567
568
569
570
571
572
573
574
575
576
        cas.setDocumentText("Some Text");
        System.out.println("UIMA AS Client Sending CAS#" + (i + 1) + " Request to a Service");
        uimaAsEngine.sendCAS(cas);
      }
     
      uimaAsEngine.stop();
      broker.stop();

      synchronized(this) {
        wait(2000);   // allow broker some time to stop 
      }
View Full Code Here
663
664
665
666
667
668
669
670
671
672
673
          cas.release();
        }
      }
     
      uimaClient1.stop();
      uimaClient2.stop();
      broker.stop();

      System.clearProperty("BrokerURL");
     
      synchronized(this) {
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.