Modifier and Type | Method and Description |
---|---|
InProcessCache.CacheEntry |
InProcessCache.getCacheEntryForCAS(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,
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,
String aCasReferenceId) |
InProcessCache.CacheEntry |
InProcessCache.register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.XmiSerializationSharedData sharedData,
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,
String aCasReferenceId,
boolean notifyOnJmsException) |
void |
OutputChannel.sendReply(org.apache.uima.resource.metadata.ProcessingResourceMetaData aProcessingResourceMetadata,
Endpoint anEndpoint,
boolean serialize) |
void |
OutputChannel.sendReply(Throwable t,
String aCasReferenceId,
String aParentCasReferenceId,
Endpoint anEndpoint,
int aCommand) |
void |
OutputChannel.sendRequest(int aCommand,
String aCasReferenceId,
Endpoint anEndpoint) |
Modifier and Type | Method and Description |
---|---|
void |
AggregateAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint) |
void |
AnalysisEngineControllerAdapter.collectionProcessComplete(Endpoint anEndpoint) |
void |
AnalysisEngineController.collectionProcessComplete(Endpoint anEndpoint) |
boolean |
AggregateAnalysisEngineController_impl.continueOnError(String aCasReferenceId,
String aDelegateKey,
Exception anException) |
boolean |
AggregateAnalysisEngineController.continueOnError(String aCasReferenceId,
String aDelegateKey,
Exception anException) |
boolean |
AggregateAnalysisEngineController_impl.delayCasIfDelegateInTimedOutState(String aCasReferenceId,
String aDelegateKey)
Checks the state of a delegate to see if it is in TIMEOUT State.
|
boolean |
AggregateAnalysisEngineController.delayCasIfDelegateInTimedOutState(String aCasReferenceId,
String aDelegateKey) |
void |
AggregateAnalysisEngineController_impl.disableDelegates(List aDelegateList) |
void |
AggregateAnalysisEngineController.disableDelegates(List aDelegateList) |
protected void |
AggregateAnalysisEngineController_impl.disableDelegates(List aDelegateList,
String aCasReferenceId) |
void |
AggregateAnalysisEngineController_impl.dispatchMetadataRequest(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController.dispatchMetadataRequest(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.enableDelegates(List aDelegateList) |
void |
AggregateAnalysisEngineController.enableDelegates(List aDelegateList) |
void |
AggregateAnalysisEngineController_impl.initialize() |
void |
Endpoint_impl.initialize() |
void |
PrimitiveAnalysisEngineController_impl.initialize() |
void |
AnalysisEngineControllerAdapter.initialize() |
void |
AnalysisEngineController.initialize() |
void |
Endpoint.initialize() |
Endpoint |
AggregateAnalysisEngineController_impl.lookUpEndpoint(String anAnalysisEngineKey,
boolean clone) |
Endpoint |
AggregateAnalysisEngineController.lookUpEndpoint(String anAnalysisEngineKey,
boolean clone) |
void |
AggregateAnalysisEngineController_impl.mergeTypeSystem(String aTypeSystem,
String fromDestination) |
void |
AggregateAnalysisEngineController.mergeTypeSystem(String aTypeSystem,
String fromDestination) |
void |
AggregateAnalysisEngineController_impl.mergeTypeSystem(String aTypeSystem,
String fromDestination,
String fromServer) |
void |
AggregateAnalysisEngineController.mergeTypeSystem(String aTypeSystem,
String fromDestination,
String fromServer) |
void |
AggregateAnalysisEngineController_impl.processCollectionCompleteReplyFromDelegate(String aDelegateKey,
boolean sendReply) |
void |
AggregateAnalysisEngineController.processCollectionCompleteReplyFromDelegate(String aDelegateKey,
boolean sendReply) |
void |
AggregateAnalysisEngineController_impl.retryMetadataRequest(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController.retryMetadataRequest(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.retryProcessCASRequest(String aCasReferenceId,
Endpoint anEndpoint,
boolean addEndpointToCache) |
void |
AggregateAnalysisEngineController.retryProcessCASRequest(String aCasReferenceId,
Endpoint anEndpoint,
boolean addEndpointToCache) |
void |
PrimitiveAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint) |
void |
AnalysisEngineControllerAdapter.sendMetadata(Endpoint anEndpoint) |
void |
AnalysisEngineController.sendMetadata(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.sendRequestForMetadataToRemoteDelegates() |
void |
AggregateAnalysisEngineController.sendRequestForMetadataToRemoteDelegates() |
void |
ControllerLatch.waitUntilInitialized() |
Modifier and Type | Method and Description |
---|---|
protected void |
HandlerBase.aggregateDelegateStats(MessageContext aMessageContext,
String aCasReferenceId) |
protected void |
HandlerBase.computeStats(MessageContext aMessageContext,
String aCasReferenceId) |
void |
HandlerBase.delegate(MessageContext aMessageContext) |
void |
Handler.delegate(MessageContext aMessageContext) |
void |
HandlerBase.handle(Object anObjectToHandle) |
void |
Handler.handle(Object anObjectToHandle) |
void |
HandlerBase.handle(Object anObjectToHandle,
String expectedOutputType) |
void |
Handler.handle(Object anObjectToHandle,
String expectedOutputType) |
void |
HandlerBase.invokeProcess(org.apache.uima.cas.CAS aCAS,
String anInputCasReferenceId,
String aNewCasReferenceId,
MessageContext aMessageContext,
String aNewCasProducedBy) |
void |
Handler.invokeProcess(org.apache.uima.cas.CAS aCAS,
String casReferenceId1,
String aCasReferenceId2,
MessageContext aMessageContext,
String aNewCasProducedBy) |
boolean |
HandlerBase.isHandlerForMessage(MessageContext aMessageContext,
int anExpectedMessageType,
int anExpectedCommand) |
boolean |
Handler.isHandlerForMessage(MessageContext aMessageContext,
int anExpectedMessageType,
int anExpectedCommand) |
void |
HandlerBase.validate(Object anObjectToHandle) |
Modifier and Type | Method and Description |
---|---|
void |
ProcessResponseHandler.handle(Object anObjectToHandle) |
Modifier and Type | Method and Description |
---|---|
byte[] |
MessageContext.getByteMessage() |
boolean |
MessageContext.getMessageBooleanProperty(String aMessagePropertyName) |
int |
MessageContext.getMessageIntProperty(String aMessagePropertyName) |
long |
MessageContext.getMessageLongProperty(String aMessagePropertyName) |
Object |
MessageContext.getMessageObjectProperty(String aMessagePropertyName) |
String |
MessageContext.getMessageStringProperty(String aMessagePropertyName) |
Object |
MessageContext.getObjectMessage() |
String |
MessageContext.getStringMessage() |
boolean |
MessageContext.propertyExists(String aKey) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
UimaMessage.toMessageContext(String anEndpointName) |
Modifier and Type | Method and Description |
---|---|
byte[] |
VmMessageContext.getByteMessage() |
boolean |
VmMessageContext.getMessageBooleanProperty(String messagePropertyName) |
int |
VmMessageContext.getMessageIntProperty(String messagePropertyName) |
long |
VmMessageContext.getMessageLongProperty(String messagePropertyName) |
Object |
VmMessageContext.getMessageObjectProperty(String messagePropertyName) |
String |
VmMessageContext.getMessageStringProperty(String messagePropertyName) |
Object |
VmMessageContext.getObjectMessage() |
String |
VmMessageContext.getStringMessage() |
boolean |
VmMessageContext.propertyExists(String key) |
MessageContext |
UimaVmMessage.toMessageContext(String anEndpointName) |
Constructor and Description |
---|
VmMessageContext(UimaVmMessage aMessage,
String anEndpointName) |
Modifier and Type | Method and Description |
---|---|
void |
JmsOutputChannel.initialize() |
void |
JmsEndpointConnection_impl.open() |
void |
JmsEndpointConnection_impl.open(String brokerUri,
String anEndpointName) |
javax.jms.BytesMessage |
JmsEndpointConnection_impl.produceByteMessage(byte[] aSerializedCAS) |
javax.jms.ObjectMessage |
JmsEndpointConnection_impl.produceObjectMessage() |
javax.jms.TextMessage |
JmsEndpointConnection_impl.produceTextMessage(String aTextMessage) |
void |
JmsOutputChannel.sendReply(InProcessCache.CacheEntry entry,
Endpoint anEndpoint) |
void |
JmsOutputChannel.sendReply(int aCommand,
Endpoint anEndpoint,
String aCasReferenceId,
boolean notifyOnJmsException) |
void |
JmsOutputChannel.sendReply(org.apache.uima.resource.metadata.ProcessingResourceMetaData aProcessingResourceMetadata,
Endpoint anEndpoint,
boolean serialize) |
void |
JmsOutputChannel.sendReply(Throwable t,
String aCasReferenceId,
String aParentCasReferenceId,
Endpoint anEndpoint,
int aCommand)
Sends JMS Reply Message to a given endpoint.
|
void |
JmsOutputChannel.sendRequest(int aCommand,
String aCasReferenceId,
Endpoint anEndpoint)
Sends request message to a delegate.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BaseUIMAAsynchronousEngineCommon_impl.delayCasIfDelegateInTimedOutState(String aCasReferenceId)
Checks the state of a delegate to see if it is in TIMEOUT State.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
JmsMessageContext.getByteMessage() |
boolean |
JmsMessageContext.getMessageBooleanProperty(String aMessagePropertyName) |
int |
JmsMessageContext.getMessageIntProperty(String aMessagePropertyName) |
long |
JmsMessageContext.getMessageLongProperty(String aMessagePropertyName) |
Object |
JmsMessageContext.getMessageObjectProperty(String aMessagePropertyName) |
String |
JmsMessageContext.getMessageStringProperty(String aMessagePropertyName) |
Object |
JmsMessageContext.getObjectMessage() |
String |
JmsMessageContext.getStringMessage() |
boolean |
JmsMessageContext.propertyExists(String aKey) |
Constructor and Description |
---|
JmsMessageContext(javax.jms.Message aMessage,
String anEndpointName) |
Copyright © 2017. All rights reserved.