My service is a aggregate analysis engine that receives input CAS
with the direcction of a directory of documents, the first component
is a MultiplerCas that for each document generate a child CAS, each
child CAS continues the flow that are other primitive annotators
(primitive annotators in c++ that can throw exceptions), then exists
other MultiplerCas that acts as Merger, waiting the complete
processing of each child CAS and finally generate a child CAS where
each child CAS previously processed is a view of CAS, this a child CAS
that is composed of view continúa el flujo a otro AE, que espera un
CAS de esta manera.
I will send you my uima-as descriptor, to understand better my
service. All delegates are co-located.
i will trys with uima-as-2.9.0 snapshot how you say, to see how it behaves
<?xml version="1.0" encoding="UTF-8"?>
<analysisEngineDeploymentDescription
xmlns="http://uima.apache.org/resourceSpecifier";>
<name>AnalyzerAE Deploy Descriptor</name>
<description>Deploys AnalyzerAE</description>
<deployment protocol="jms" provider="activemq">
<service>
<inputQueue endpoint="AnalyzerAggregate" brokerURL="${defaultBrokerURL}"/>
<topDescriptor>
<import location="./AnalyzerAggregate.xml"/>
</topDescriptor>
<analysisEngine inputQueueScaleout="2" internalReplyQueueScaleout="3">
<delegates>
<analysisEngine key="FileSystemMultiplerCas">
<casMultiplier poolSize="10"/>
</analysisEngine>
<analysisEngine key="XFileFormatDetector">
<scaleout numberOfInstances="2"/>
<asyncAggregateErrorConfiguration>
<processCasErrors maxRetries="0" continueOnRetryFailure="true"/>
</asyncAggregateErrorConfiguration>
</analysisEngine>
<analysisEngine key="XDataFileExtractor">
<scaleout numberOfInstances="2"/>
<asyncAggregateErrorConfiguration>
<processCasErrors maxRetries="0" continueOnRetryFailure="true"/>
</asyncAggregateErrorConfiguration>
</analysisEngine>
<analysisEngine key="XTokenizer">
<scaleout numberOfInstances="2"/>
<asyncAggregateErrorConfiguration>
<processCasErrors maxRetries="0" continueOnRetryFailure="true"/>
</asyncAggregateErrorConfiguration>
</analysisEngine>
<analysisEngine key="XLanguageDetector">
<scaleout numberOfInstances="2"/>
<asyncAggregateErrorConfiguration>
<processCasErrors maxRetries="0" continueOnRetryFailure="true"/>
</asyncAggregateErrorConfiguration>
</analysisEngine>
<analysisEngine key="XBoTModeler">
<scaleout numberOfInstances="3"/>
<asyncAggregateErrorConfiguration>
<processCasErrors maxRetries="0" continueOnRetryFailure="true"/>
</asyncAggregateErrorConfiguration>
</analysisEngine>
<analysisEngine key="MergerInViewCasMultipler">
<casMultiplier poolSize="1"/>
</analysisEngine>
<analysisEngine key="Analyzer">
<scaleout numberOfInstances="1"/>
<asyncAggregateErrorConfiguration>
<processCasErrors maxRetries="0" continueOnRetryFailure="true"/>
</asyncAggregateErrorConfiguration>
</analysisEngine>
</delegates>
</analysisEngine>
</service>
</deployment>
</analysisEngineDeploymentDescription>
