Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
AnalysisEngineControllerAdapter.collectionProcessComplete(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController_impl.collectionProcessComplete(Endpoint anEndpoint) |
void |
AnalysisEngineController.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 |
AnalysisEngineControllerAdapter.initialize() |
void |
PrimitiveAnalysisEngineController_impl.initialize() |
void |
Endpoint.initialize() |
void |
AggregateAnalysisEngineController_impl.initialize() |
void |
AnalysisEngineController.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 |
AnalysisEngineControllerAdapter.sendMetadata(Endpoint anEndpoint) |
void |
PrimitiveAnalysisEngineController_impl.sendMetadata(Endpoint anEndpoint) |
void |
AnalysisEngineController.sendMetadata(Endpoint anEndpoint) |
void |
AggregateAnalysisEngineController.sendRequestForMetadataToRemoteDelegates() |
void |
AggregateAnalysisEngineController_impl.sendRequestForMetadataToRemoteDelegates() |
void |
ControllerLatch.waitUntilInitialized() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
ProcessResponseHandler.handle(java.lang.Object anObjectToHandle) |
Modifier and Type | Method and Description |
---|---|
byte[] |
MessageContext.getByteMessage() |
boolean |
MessageContext.getMessageBooleanProperty(java.lang.String aMessagePropertyName) |
int |
MessageContext.getMessageIntProperty(java.lang.String aMessagePropertyName) |
long |
MessageContext.getMessageLongProperty(java.lang.String aMessagePropertyName) |
java.lang.Object |
MessageContext.getMessageObjectProperty(java.lang.String aMessagePropertyName) |
java.lang.String |
MessageContext.getMessageStringProperty(java.lang.String aMessagePropertyName) |
java.lang.Object |
MessageContext.getObjectMessage() |
java.lang.String |
MessageContext.getStringMessage() |
boolean |
MessageContext.propertyExists(java.lang.String aKey) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
UimaMessage.toMessageContext(java.lang.String anEndpointName) |
Modifier and Type | Method and Description |
---|---|
byte[] |
VmMessageContext.getByteMessage() |
boolean |
VmMessageContext.getMessageBooleanProperty(java.lang.String messagePropertyName) |
int |
VmMessageContext.getMessageIntProperty(java.lang.String messagePropertyName) |
long |
VmMessageContext.getMessageLongProperty(java.lang.String messagePropertyName) |
java.lang.Object |
VmMessageContext.getMessageObjectProperty(java.lang.String messagePropertyName) |
java.lang.String |
VmMessageContext.getMessageStringProperty(java.lang.String messagePropertyName) |
java.lang.Object |
VmMessageContext.getObjectMessage() |
java.lang.String |
VmMessageContext.getStringMessage() |
boolean |
VmMessageContext.propertyExists(java.lang.String key) |
MessageContext |
UimaVmMessage.toMessageContext(java.lang.String anEndpointName) |
Constructor and Description |
---|
VmMessageContext(UimaVmMessage aMessage,
java.lang.String anEndpointName) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BaseUIMAAsynchronousEngineCommon_impl.delayCasIfDelegateInTimedOutState(java.lang.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(java.lang.String aMessagePropertyName) |
int |
JmsMessageContext.getMessageIntProperty(java.lang.String aMessagePropertyName) |
long |
JmsMessageContext.getMessageLongProperty(java.lang.String aMessagePropertyName) |
java.lang.Object |
JmsMessageContext.getMessageObjectProperty(java.lang.String aMessagePropertyName) |
java.lang.String |
JmsMessageContext.getMessageStringProperty(java.lang.String aMessagePropertyName) |
java.lang.Object |
JmsMessageContext.getObjectMessage() |
java.lang.String |
JmsMessageContext.getStringMessage() |
boolean |
JmsMessageContext.propertyExists(java.lang.String aKey) |
Constructor and Description |
---|
JmsMessageContext(javax.jms.Message aMessage,
java.lang.String anEndpointName) |
Copyright © 2012. All Rights Reserved.