Methods in org.apache.uima.aae with parameters of type Endpoint |
protected void |
InProcessCache.CacheEntry.addEndpoint(Endpoint anEndpoint)
|
void |
InProcessCache.addEndpoint(Endpoint anEndpoint,
java.lang.String aCasReferenceId)
|
void |
InProcessCache.CacheEntry.addOrigin(Endpoint anEndpoint)
|
void |
OutputChannel.bindWithClientEndpoint(Endpoint anEndpoint)
|
void |
InputChannel.createListener(java.lang.String aDelegateKey,
Endpoint endpointToUpdate)
|
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)
|
void |
InProcessCache.CacheEntry.setFreeCasEndpoint(Endpoint aFreeCasEndpoint)
|
Methods in org.apache.uima.aae.controller with parameters of type Endpoint |
void |
AggregateAnalysisEngineController.addMessageOrigin(java.lang.String aCasReferenceId,
Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.addMessageOrigin(java.lang.String aCasReferenceId,
Endpoint anEndpoint)
|
void |
BaseAnalysisEngineController.cacheClientEndpoint(Endpoint anEndpoint)
|
void |
AnalysisEngineController.cacheClientEndpoint(Endpoint anEndpoint)
|
void |
AnalysisEngineControllerAdapter.cacheClientEndpoint(Endpoint anEndpoint)
|
void |
AnalysisEngineController.collectionProcessComplete(Endpoint anEndpoint)
|
void |
PrimitiveAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint)
|
void |
AnalysisEngineControllerAdapter.collectionProcessComplete(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController.dispatchMetadataRequest(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.dispatchMetadataRequest(Endpoint anEndpoint)
|
void |
BaseAnalysisEngineController.process(org.apache.uima.cas.CAS aCAS,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
|
void |
AnalysisEngineController.process(org.apache.uima.cas.CAS aCAS,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
|
void |
PrimitiveAnalysisEngineController_impl.process(org.apache.uima.cas.CAS aCAS,
java.lang.String aCasReferenceId,
Endpoint anEndpoint)
This is called when a Stop request is received from a client. |
void |
AnalysisEngineControllerAdapter.process(org.apache.uima.cas.CAS acas,
java.lang.String casReferenceId,
Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController.retryLastCommand(int aCommand,
Endpoint anEndpoint,
java.lang.String aCasReferenceId)
|
void |
AggregateAnalysisEngineController_impl.retryLastCommand(int aCommand,
Endpoint anEndpoint,
java.lang.String aCasReferenceId)
|
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 |
AnalysisEngineController.sendMetadata(Endpoint anEndpoint)
|
void |
PrimitiveAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint)
|
void |
AnalysisEngineControllerAdapter.sendMetadata(Endpoint anEndpoint)
|
void |
AggregateAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint)
|
void |
BaseAnalysisEngineController.sendMetadata(Endpoint anEndpoint,
org.apache.uima.analysis_engine.metadata.AnalysisEngineMetaData metadata)
|
void |
LocalCache.CasStateEntry.setFreeCasNotificationEndpoint(Endpoint freeCasNotificationEndpoint)
|
Methods in org.apache.uima.adapter.jms.activemq with parameters of type Endpoint |
void |
JmsOutputChannel.bindWithClientEndpoint(Endpoint anEndpoint)
This method verifies that the destination (queue) exists. |
void |
JmsInputChannel.createListener(java.lang.String aDelegateKey,
Endpoint endpointToUpdate)
|
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. |
protected void |
JmsEndpointConnection_impl.setDelegateEndpoint(Endpoint delegateEndpoint)
|
void |
UimaDefaultMessageListenerContainer.setTargetEndpoint(Endpoint anEndpoint)
|
void |
JmsOutputChannel.ConnectionTimer.startTimer(long aConnectionCreationTimestamp,
Endpoint endpoint)
|
void |
JmsOutputChannel.ConnectionTimer.startTimer(long aConnectionCreationTimestamp,
Endpoint endpoint,
long currentInactivityTimeout,
java.lang.String aComponentName)
|