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

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

515
516
517
518
519
520
521
522
523
524
525
        cas.setDocumentText("Some Text");
        System.out.println("UIMA AS Client Sending CAS#" + (i + 1) + " Request to a Service");
        uimaAsEngine.sendCAS(cas);
      }
     
      uimaAsEngine.stop();
      super.cleanBroker(broker2);
      broker2.stop();
      synchronized(this) {
        wait(3000);   // allow broker some time to stop 
     }
View Full Code Here
557
558
559
560
561
562
563
564
565
566
567
        cas.setDocumentText("Some Text");
        System.out.println("UIMA AS Client Sending CAS#" + (i + 1) + " Request to a Service");
        uimaAsEngine.sendCAS(cas);
      }
     
      uimaAsEngine.stop();
      super.cleanBroker(broker2);

      broker2.stop();

      synchronized(this) {
View Full Code Here
654
655
656
657
658
659
660
661
662
663
664
          cas.release();
        }
      }
     
      uimaClient1.stop();
      uimaClient2.stop();
      super.cleanBroker(broker2);

      broker2.stop();

      synchronized(this) {
View Full Code Here
720
721
722
723
724
725
726
727
728
729
730
          System.out.println("UIMA AS Client Received Expected Error on CAS:"+(i+1));
        } finally {
          cas.release();
        }
      }
      uimaClient1.stop();
      System.out.println("Stopping Broker - wait ...");
      super.cleanBroker(broker2);

      broker2.stop();
View Full Code Here
757
758
759
760
761
762
763
764
765
766
767
        cas.setDocumentText("Some Text");
        uimaAsEngine.sendCAS(cas);  // will timeout after 5 secs
        uimaAsEngine.collectionProcessingComplete();  // the CPC should not
        // be sent to a service until the timeout occurs.
      }
      uimaAsEngine.stop();
  }
 
  public void testClientProcess() throws Exception {
    System.out.println("-------------- testClientProcess -------------");
    // Instantiate Uima AS Client
View Full Code Here
782
783
784
785
786
787
788
789
790
791
792
      uimaAsEngine.sendCAS(cas);
    }
   
    uimaAsEngine.collectionProcessingComplete();
    System.clearProperty("DefaultBrokerURL");
    uimaAsEngine.stop();
  }
 
 
  public void testClientProcessTimeout() throws Exception {
    System.out
View Full Code Here
807
808
809
810
811
812
813
814
815
816
817
      System.out.println("UIMA AS Client Sending CAS#" + (i + 1) + " Request to a Service");
      uimaAsEngine.sendCAS(cas);
    }
   
    uimaAsEngine.collectionProcessingComplete();
    uimaAsEngine.stop();
 
 
  }
 
 
View Full Code Here
832
833
834
835
836
837
838
839
840
841
842
      cas.setDocumentText("Some Text");
      System.out.println("UIMA AS Client Sending CAS#" + (i + 1) + " Request to a Service");
      uimaAsEngine.sendCAS(cas);
    }
    uimaAsEngine.collectionProcessingComplete();
    uimaAsEngine.stop();
   
  }

  public void testClientCpcTimeout() throws Exception {
    System.out.println("-------------- testClientCpcTimeout -------------");
View Full Code Here
884
885
886
887
888
889
890
891
892
893
894
        System.out.println("Received Expected Exception:" + UIMA_IllegalStateException.class);
      }
    } catch (ServiceShutdownException e) {
      // expected
    } finally {
      eeUimaEngine.stop();
    }
  }

  /**
   * Tests deployment of a primitive Uima EE Service (PersontTitleAnnotator). Deploys the primitive
View Full Code Here
961
962
963
964
965
966
967
968
969
970
971
     
    } catch (ResourceInitializationException e) {
        fail("Initialization Exception");
    } catch (Exception e) {
    } finally {
      eeUimaEngine.stop();
    }
  }

  /**
   * Tests detection of misconfiguration between deployement descriptor and AE descriptor.
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.