@Test(expected = Exception.class) public void testInitNullListener() throws Exception { Client c = new Client(); assertNotNull(c); c.init(null); }
protected void init(UimaAsBaseCallbackListener... uabs) throws Exception { if (uabs != null) { for (UimaAsBaseCallbackListener uab : uabs) { this.addUABListener(uab); } } validateData(); if (this.mBrokerURL != null) mAppCtx.put(UimaAsynchronousEngine.ServerUri, this.mBrokerURL); if (this.mEndpoint != null) mAppCtx.put(UimaAsynchronousEngine.ENDPOINT, this.mEndpoint); mAppCtx.put(UimaAsynchronousEngine.Timeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.GetMetaTimeout, mInitTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CpcTimeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CasPoolSize, mCasPoolSize); mAppCtx.put(UIMAFramework.CAS_INITIAL_HEAP_SIZE, Integer.valueOf(mFSHeapSize / 4).toString()); }
Client extends LeoProperties { protected void init(UimaAsBaseCallbackListener... uabs) throws Exception { if (uabs != null) { for (UimaAsBaseCallbackListener uab : uabs) { this.addUABListener(uab); } } validateData(); if (this.mBrokerURL != null) mAppCtx.put(UimaAsynchronousEngine.ServerUri, this.mBrokerURL); if (this.mEndpoint != null) mAppCtx.put(UimaAsynchronousEngine.ENDPOINT, this.mEndpoint); mAppCtx.put(UimaAsynchronousEngine.Timeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.GetMetaTimeout, mInitTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CpcTimeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CasPoolSize, mCasPoolSize); mAppCtx.put(UIMAFramework.CAS_INITIAL_HEAP_SIZE, Integer.valueOf(mFSHeapSize / 4).toString()); } }
Client extends LeoProperties { protected void init(UimaAsBaseCallbackListener... uabs) throws Exception { if (uabs != null) { for (UimaAsBaseCallbackListener uab : uabs) { this.addUABListener(uab); } } validateData(); if (this.mBrokerURL != null) mAppCtx.put(UimaAsynchronousEngine.ServerUri, this.mBrokerURL); if (this.mEndpoint != null) mAppCtx.put(UimaAsynchronousEngine.ENDPOINT, this.mEndpoint); mAppCtx.put(UimaAsynchronousEngine.Timeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.GetMetaTimeout, mInitTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CpcTimeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CasPoolSize, mCasPoolSize); mAppCtx.put(UIMAFramework.CAS_INITIAL_HEAP_SIZE, Integer.valueOf(mFSHeapSize / 4).toString()); } Client(UimaAsBaseCallbackListener... uaListeners);  Client(String propertiesFile, UimaAsBaseCallbackListener... uaListeners);  Client(String propertiesFile, LeoCollectionReaderInterface collectionReader, UimaAsBaseCallbackListener... uaListeners); }
Client extends LeoProperties { protected void init(UimaAsBaseCallbackListener... uabs) throws Exception { if (uabs != null) { for (UimaAsBaseCallbackListener uab : uabs) { this.addUABListener(uab); } } validateData(); if (this.mBrokerURL != null) mAppCtx.put(UimaAsynchronousEngine.ServerUri, this.mBrokerURL); if (this.mEndpoint != null) mAppCtx.put(UimaAsynchronousEngine.ENDPOINT, this.mEndpoint); mAppCtx.put(UimaAsynchronousEngine.Timeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.GetMetaTimeout, mInitTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CpcTimeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CasPoolSize, mCasPoolSize); mAppCtx.put(UIMAFramework.CAS_INITIAL_HEAP_SIZE, Integer.valueOf(mFSHeapSize / 4).toString()); } Client(UimaAsBaseCallbackListener... uaListeners);  Client(String propertiesFile, UimaAsBaseCallbackListener... uaListeners);  Client(String propertiesFile, LeoCollectionReaderInterface collectionReader, UimaAsBaseCallbackListener... uaListeners); void setLeoCollectionReader(LeoCollectionReaderInterface reader); LeoCollectionReaderInterface getLeoCollectionReader(); void addUABListener(UimaAsBaseCallbackListener uaListener); void validateData(); void run(UimaAsBaseCallbackListener... uabs); void run(LeoCollectionReaderInterface collectionReader, UimaAsBaseCallbackListener... uabs); void run(InputStream stream, UimaAsBaseCallbackListener... uabs); void run(String documentText, UimaAsBaseCallbackListener... uabs); void run(CAS cas, UimaAsBaseCallbackListener... uabs); List getListeners(); String getPerformanceReport(); static TypeSystemDescription getServiceTypeSystemDescription(String brokerURL, String inputQueueName); TypeSystemDescription getServiceTypeSystemDescription(); static String getServiceTypeSystemDescriptionXml(String brokerURL, String inputQueueName); String getServiceTypeSystemDescriptionXml(); }
Client extends LeoProperties { protected void init(UimaAsBaseCallbackListener... uabs) throws Exception { if (uabs != null) { for (UimaAsBaseCallbackListener uab : uabs) { this.addUABListener(uab); } } validateData(); if (this.mBrokerURL != null) mAppCtx.put(UimaAsynchronousEngine.ServerUri, this.mBrokerURL); if (this.mEndpoint != null) mAppCtx.put(UimaAsynchronousEngine.ENDPOINT, this.mEndpoint); mAppCtx.put(UimaAsynchronousEngine.Timeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.GetMetaTimeout, mInitTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CpcTimeout, mCCTimeout * 1000); mAppCtx.put(UimaAsynchronousEngine.CasPoolSize, mCasPoolSize); mAppCtx.put(UIMAFramework.CAS_INITIAL_HEAP_SIZE, Integer.valueOf(mFSHeapSize / 4).toString()); } Client(UimaAsBaseCallbackListener... uaListeners);  Client(String propertiesFile, UimaAsBaseCallbackListener... uaListeners);  Client(String propertiesFile, LeoCollectionReaderInterface collectionReader, UimaAsBaseCallbackListener... uaListeners); void setLeoCollectionReader(LeoCollectionReaderInterface reader); LeoCollectionReaderInterface getLeoCollectionReader(); void addUABListener(UimaAsBaseCallbackListener uaListener); void validateData(); void run(UimaAsBaseCallbackListener... uabs); void run(LeoCollectionReaderInterface collectionReader, UimaAsBaseCallbackListener... uabs); void run(InputStream stream, UimaAsBaseCallbackListener... uabs); void run(String documentText, UimaAsBaseCallbackListener... uabs); void run(CAS cas, UimaAsBaseCallbackListener... uabs); List getListeners(); String getPerformanceReport(); static TypeSystemDescription getServiceTypeSystemDescription(String brokerURL, String inputQueueName); TypeSystemDescription getServiceTypeSystemDescription(); static String getServiceTypeSystemDescriptionXml(String brokerURL, String inputQueueName); String getServiceTypeSystemDescriptionXml();  }