import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
@Test(expected = ResourceProcessException.class)
public void testRunReaderBadTypeSystem() throws Exception {
    XmiFileCollectionReader reader = new XmiFileCollectionReader(xmiTestBadCorpus, false);
    assertNotNull(reader);
    DoNothingListener listener = new DoNothingListener();
    MockClient client = new MockClient();
    assertNotNull(client);
    assertNotNull(listener);

    //Add the type system
    client.getEngine().setAnalysisEngineFromDescription(
            simpleServiceDefinition(
                    new LeoTypeSystemDescription(new File(xmiTestBadCorpus, "type-system.xml").getAbsolutePath(), false)
            )
    );

    //Run the client
    client.run(reader, listener);
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
/**
 * process
 */
public void processCas(CAS aCAS) throws ResourceProcessException {

	JCas jcas;
	try {
		jcas = aCAS.getJCas();
	} catch (CASException e) {
		throw new ResourceProcessException(e);
	}

	printTimexAnnotations(jcas);
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
/**
 * process
 */
public void processCas(CAS aCAS) throws ResourceProcessException {

	JCas jcas;
	try {
		jcas = aCAS.getJCas();
	} catch (CASException e) {
		throw new ResourceProcessException(e);
	}

	printTimexAnnotationsInline(jcas);
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
public synchronized void process() throws ResourceProcessException {
    try {
        List listeners = this.getListeners();
        while (collectionReader.hasNext()) {
            CAS cas = ae.newCAS();
            collectionReader.getNext(cas);
            sendCAS(cas);
        }
        this.collectionProcessingComplete();
    } catch (Exception e) {
        throw new ResourceProcessException(e);
    }
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
public synchronized String sendCAS(CAS aCAS) throws ResourceProcessException {
    List listeners = this.getListeners();
    ae.process(aCAS);
    for (int i = 0; listeners != null && i < listeners.size(); i++) {
        UimaAsBaseCallbackListener listener = (UimaAsBaseCallbackListener) listeners.get(i);
        listener.onBeforeMessageSend(new MockUimaASProcessStatus());
        listener.entityProcessComplete(aCAS, null);
    }
    return UUID.randomUUID().toString();
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
public synchronized void collectionProcessingComplete() throws ResourceProcessException {
    List listeners = this.getListeners();
    for (int i = 0; listeners != null && i < listeners.size(); i++) {
        UimaAsBaseCallbackListener listener = (UimaAsBaseCallbackListener) listeners.get(i);
        listener.collectionProcessComplete(null);
    }
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
@Override
public void process(CAS aCAS) throws AnalysisEngineProcessException {
  try {
    processCas(aCAS);
  } catch (ResourceProcessException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }
  
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
/**
 * Called if the processing is finished, 
 */
public void collectionProcessComplete(ProcessTrace trace)
throws ResourceProcessException, IOException {
	
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
/**
 * Called when the entire collection is completed.
 * 
 * @param aTrace
 *          ProcessTrace object that will log events in this method.
 * @throws ResourceProcessException
 *           if there is an error in processing the Resource
 * @throws IOException
 *           if there is an IO Error
 * @see org.apache.uima.collection.CasConsumer#collectionProcessComplete(ProcessTrace)
 */
public void collectionProcessComplete(ProcessTrace aTrace) throws ResourceProcessException,
        IOException {
  if (fileWriter != null) {
    fileWriter.close();
  }
}
 

import org.apache.uima.resource.ResourceProcessException; //导入依赖的package包/类
/**
 * Called when a batch of processing is completed.
 * 
 * @param aTrace
 *          ProcessTrace object that will log events in this method.
 * @throws ResourceProcessException
 *           if there is an error in processing the Resource
 * @throws IOException
 *           if there is an IO Error
 * 
 * @see org.apache.uima.collection.CasConsumer#batchProcessComplete(ProcessTrace)
 */
public void batchProcessComplete(ProcessTrace aTrace) throws ResourceProcessException,
        IOException {
  // nothing to do in this case as AnnotationPrinter doesnot do
  // anything cumulatively
}