Modifier and Type | Method and Description |
---|---|
protected Endpoint |
InProcessCache.CacheEntry.getEndpoint(java.lang.String anEndpointName) |
Endpoint |
InProcessCache.getEndpoint(java.lang.String anEndpointName,
java.lang.String aCasReferenceId) |
Endpoint |
InProcessCache.CacheEntry.getFreeCasEndpoint() |
Endpoint |
InProcessCache.CacheEntry.getMessageOrigin() |
Endpoint |
InProcessCache.getTopAncestorEndpoint(InProcessCache.CacheEntry anEntry) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Class and Description |
---|---|
class |
Endpoint_impl |
Modifier and Type | Field and Description |
---|---|
protected Endpoint |
BaseAnalysisEngineController.clientEndpoint |
Modifier and Type | Method and Description |
---|---|
Endpoint |
AnalysisEngineControllerAdapter.getClientEndpoint() |
Endpoint |
BaseAnalysisEngineController.getClientEndpoint() |
Endpoint |
AnalysisEngineController.getClientEndpoint() |
Endpoint |
LocalCache.CasStateEntry.getFreeCasNotificationEndpoint() |
Endpoint |
AggregateAnalysisEngineController.getMessageOrigin(java.lang.String aCasReferenceId) |
Endpoint |
AggregateAnalysisEngineController_impl.getMessageOrigin(java.lang.String aCasReferenceId) |
Endpoint |
AggregateAnalysisEngineController.lookUpEndpoint(java.lang.String anAnalysisEngineKey,
boolean clone) |
Endpoint |
AggregateAnalysisEngineController_impl.lookUpEndpoint(java.lang.String anAnalysisEngineKey,
boolean clone) |
Modifier and Type | Method and Description |
---|---|
void |
AggregateAnalysisEngineController.addMessageOrigin(java.lang.String aCasReferenceId,
Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.addMessageOrigin(java.lang.String aCasReferenceId,
Endpoint anEndpoint) |
void |
AnalysisEngineControllerAdapter.cacheClientEndpoint(Endpoint anEndpoint) |
void |
BaseAnalysisEngineController.cacheClientEndpoint(Endpoint anEndpoint) |
void |
AnalysisEngineController.cacheClientEndpoint(Endpoint anEndpoint) |
void |
AnalysisEngineControllerAdapter.collectionProcessComplete(Endpoint anEndpoint) |
void |
PrimitiveAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint) |
void |
AnalysisEngineController.collectionProcessComplete(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController.dispatchMetadataRequest(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.dispatchMetadataRequest(Endpoint anEndpoint) |
void |
AnalysisEngineControllerAdapter.process(org.apache.uima.cas.CAS acas,
java.lang.String casReferenceId,
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 |
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 |
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 |
AnalysisEngineControllerAdapter.sendMetadata(Endpoint anEndpoint) |
void |
PrimitiveAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint) |
void |
AnalysisEngineController.sendMetadata(Endpoint anEndpoint) |
void |
BaseAnalysisEngineController.sendMetadata(Endpoint anEndpoint,
org.apache.uima.analysis_engine.metadata.AnalysisEngineMetaData metadata) |
void |
LocalCache.CasStateEntry.setFreeCasNotificationEndpoint(Endpoint freeCasNotificationEndpoint) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
Delegate.getEndpoint()
Returns an
Endpoint object |
Endpoint |
Delegate.getNotificationEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
Delegate.setEndpoint(Endpoint anEndpoint)
Sets an
Endpoint object |
void |
Delegate.setNotificationEndpoint(Endpoint notificationEndpoint) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
ErrorHandlerBase.getDelegateKey(Endpoint anEndpoint,
AnalysisEngineController aController) |
protected Threshold |
ErrorHandlerBase.getThreshold(Endpoint anEndpoint,
java.util.Map aDelegateMap,
AnalysisEngineController aController) |
protected boolean |
ErrorHandlerBase.retryLastCommand(int aRetryCommand,
Endpoint anEndpoint,
AnalysisEngineController aController,
java.lang.String aKey,
Threshold aThreshold,
ErrorContext anErrorContext) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
MessageContext.getEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
BaseMonitor.addStatistic(java.lang.String aName,
Statistic aStatistic,
Endpoint anEndpoint) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
VmMessageContext.getEndpoint() |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
JmsEndpointConnection_impl(JmsOutputChannel.BrokerConnectionEntry aBrokerDestinationMap,
Endpoint anEndpoint,
AnalysisEngineController aController) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.MessageProducer |
BaseUIMAAsynchronousEngine_impl.lookupProducerForEndpoint(Endpoint anEndpoint) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
JmsMessageContext.getEndpoint() |
Copyright © 2012. All Rights Reserved.