Methods in org.apache.uima.aae that throw AsynchAEException |
InProcessCache.CacheEntry |
InProcessCache.getCacheEntryForCAS(java.lang.String aCasReferenceId)
|
void |
OutputChannel.initialize()
|
InProcessCache.CacheEntry |
InProcessCache.register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.OutOfTypeSystemData otsd)
|
InProcessCache.CacheEntry |
InProcessCache.register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.OutOfTypeSystemData otsd,
java.lang.String aCasReferenceId)
|
InProcessCache.CacheEntry |
InProcessCache.register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.XmiSerializationSharedData sharedData)
|
InProcessCache.CacheEntry |
InProcessCache.register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.XmiSerializationSharedData sharedData,
java.lang.String aCasReferenceId)
|
InProcessCache.CacheEntry |
InProcessCache.register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.XmiSerializationSharedData sharedData,
java.lang.String aCasReferenceId,
org.apache.uima.cas.Marker marker,
boolean acceptsDeltaCas)
|
void |
OutputChannel.sendReply(InProcessCache.CacheEntry entry,
Endpoint anEndpoint)
|
void |
OutputChannel.sendReply(int aCommand,
Endpoint anEndpoint,
java.lang.String aCasReferenceId,
boolean notifyOnJmsException)
|
void |
OutputChannel.sendReply(org.apache.uima.resource.metadata.ProcessingResourceMetaData aProcessingResourceMetadata,
Endpoint anEndpoint,
boolean serialize)
|
void |
OutputChannel.sendReply(java.lang.Throwable t,
java.lang.String aCasReferenceId,
java.lang.String aParentCasReferenceId,
Endpoint anEndpoint,
int aCommand)
|
void |
OutputChannel.sendRequest(int aCommand,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
|
Methods in org.apache.uima.aae.controller that throw AsynchAEException |
void |
AnalysisEngineController.collectionProcessComplete(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint)
|
void |
AnalysisEngineControllerAdapter.collectionProcessComplete(Endpoint anEndpoint)
|
boolean |
AggregateAnalysisEngineController.continueOnError(java.lang.String aCasReferenceId,
java.lang.String aDelegateKey,
java.lang.Exception anException)
|
boolean |
AggregateAnalysisEngineController_impl.continueOnError(java.lang.String aCasReferenceId,
java.lang.String aDelegateKey,
java.lang.Exception anException)
|
boolean |
AggregateAnalysisEngineController.delayCasIfDelegateInTimedOutState(java.lang.String aCasReferenceId,
java.lang.String aDelegateKey)
|
boolean |
AggregateAnalysisEngineController_impl.delayCasIfDelegateInTimedOutState(java.lang.String aCasReferenceId,
java.lang.String aDelegateKey)
Checks the state of a delegate to see if it is in TIMEOUT State. |
void |
AggregateAnalysisEngineController.disableDelegates(java.util.List aDelegateList)
|
void |
AggregateAnalysisEngineController_impl.disableDelegates(java.util.List aDelegateList)
|
protected void |
AggregateAnalysisEngineController_impl.disableDelegates(java.util.List aDelegateList,
java.lang.String aCasReferenceId)
|
void |
AggregateAnalysisEngineController.dispatchMetadataRequest(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.dispatchMetadataRequest(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController.enableDelegates(java.util.List aDelegateList)
|
void |
AggregateAnalysisEngineController_impl.enableDelegates(java.util.List aDelegateList)
|
void |
Endpoint_impl.initialize()
|
void |
PrimitiveAnalysisEngineController_impl.initialize()
|
void |
Endpoint.initialize()
|
void |
AnalysisEngineController.initialize()
|
void |
AggregateAnalysisEngineController_impl.initialize()
|
void |
AnalysisEngineControllerAdapter.initialize()
|
Endpoint |
AggregateAnalysisEngineController.lookUpEndpoint(java.lang.String anAnalysisEngineKey,
boolean clone)
|
Endpoint |
AggregateAnalysisEngineController_impl.lookUpEndpoint(java.lang.String anAnalysisEngineKey,
boolean clone)
|
void |
AggregateAnalysisEngineController.mergeTypeSystem(java.lang.String aTypeSystem,
java.lang.String fromDestination)
|
void |
AggregateAnalysisEngineController_impl.mergeTypeSystem(java.lang.String aTypeSystem,
java.lang.String fromDestination)
|
void |
AggregateAnalysisEngineController.mergeTypeSystem(java.lang.String aTypeSystem,
java.lang.String fromDestination,
java.lang.String fromServer)
|
void |
AggregateAnalysisEngineController_impl.mergeTypeSystem(java.lang.String aTypeSystem,
java.lang.String fromDestination,
java.lang.String fromServer)
|
void |
AggregateAnalysisEngineController.processCollectionCompleteReplyFromDelegate(java.lang.String aDelegateKey,
boolean sendReply)
|
void |
AggregateAnalysisEngineController_impl.processCollectionCompleteReplyFromDelegate(java.lang.String aDelegateKey,
boolean sendReply)
|
void |
AggregateAnalysisEngineController.retryMetadataRequest(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.retryMetadataRequest(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController.retryProcessCASRequest(java.lang.String aCasReferenceId,
Endpoint anEndpoint,
boolean addEndpointToCache)
|
void |
AggregateAnalysisEngineController_impl.retryProcessCASRequest(java.lang.String aCasReferenceId,
Endpoint anEndpoint,
boolean addEndpointToCache)
|
void |
PrimitiveAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint)
|
void |
AnalysisEngineController.sendMetadata(Endpoint anEndpoint)
|
void |
AnalysisEngineControllerAdapter.sendMetadata(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController.sendRequestForMetadataToRemoteDelegates()
|
void |
AggregateAnalysisEngineController_impl.sendRequestForMetadataToRemoteDelegates()
|
void |
ControllerLatch.waitUntilInitialized()
|
Methods in org.apache.uima.aae.handler that throw AsynchAEException |
protected void |
HandlerBase.aggregateDelegateStats(MessageContext aMessageContext,
java.lang.String aCasReferenceId)
|
protected void |
HandlerBase.computeStats(MessageContext aMessageContext,
java.lang.String aCasReferenceId)
|
void |
Handler.delegate(MessageContext aMessageContext)
|
void |
HandlerBase.delegate(MessageContext aMessageContext)
|
void |
Handler.handle(java.lang.Object anObjectToHandle)
|
void |
HandlerBase.handle(java.lang.Object anObjectToHandle)
|
void |
Handler.handle(java.lang.Object anObjectToHandle,
java.lang.String expectedOutputType)
|
void |
HandlerBase.handle(java.lang.Object anObjectToHandle,
java.lang.String expectedOutputType)
|
void |
Handler.invokeProcess(org.apache.uima.cas.CAS aCAS,
java.lang.String casReferenceId1,
java.lang.String aCasReferenceId2,
MessageContext aMessageContext,
java.lang.String aNewCasProducedBy)
|
void |
HandlerBase.invokeProcess(org.apache.uima.cas.CAS aCAS,
java.lang.String anInputCasReferenceId,
java.lang.String aNewCasReferenceId,
MessageContext aMessageContext,
java.lang.String aNewCasProducedBy)
|
boolean |
Handler.isHandlerForMessage(MessageContext aMessageContext,
int anExpectedMessageType,
int anExpectedCommand)
|
boolean |
HandlerBase.isHandlerForMessage(MessageContext aMessageContext,
int anExpectedMessageType,
int anExpectedCommand)
|
void |
HandlerBase.validate(java.lang.Object anObjectToHandle)
|
Methods in org.apache.uima.adapter.jms.activemq that throw AsynchAEException |
void |
JmsOutputChannel.initialize()
|
void |
JmsEndpointConnection_impl.open()
|
void |
JmsEndpointConnection_impl.open(java.lang.String brokerUri,
java.lang.String anEndpointName)
|
javax.jms.BytesMessage |
JmsEndpointConnection_impl.produceByteMessage(byte[] aSerializedCAS)
|
javax.jms.ObjectMessage |
JmsEndpointConnection_impl.produceObjectMessage()
|
javax.jms.TextMessage |
JmsEndpointConnection_impl.produceTextMessage(java.lang.String aTextMessage)
|
void |
JmsOutputChannel.sendReply(InProcessCache.CacheEntry entry,
Endpoint anEndpoint)
|
void |
JmsOutputChannel.sendReply(int aCommand,
Endpoint anEndpoint,
java.lang.String aCasReferenceId,
boolean notifyOnJmsException)
|
void |
JmsOutputChannel.sendReply(org.apache.uima.resource.metadata.ProcessingResourceMetaData aProcessingResourceMetadata,
Endpoint anEndpoint,
boolean serialize)
|
void |
JmsOutputChannel.sendReply(java.lang.Throwable t,
java.lang.String aCasReferenceId,
java.lang.String aParentCasReferenceId,
Endpoint anEndpoint,
int aCommand)
Sends JMS Reply Message to a given endpoint. |
void |
JmsOutputChannel.sendRequest(int aCommand,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
Sends request message to a delegate. |