Package org.apache.uima.aae.controller
Interface Endpoint
-
- All Known Implementing Classes:
Endpoint_impl
public interface Endpoint
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcancelTimer()voidclose()booleancompletedProcessingCollection()longgetCheckpointTimer()intgetCommand()intgetConcurrentReplyConsumers()intgetConcurrentRequestConsumers()java.lang.StringgetDelegateKey()java.lang.StringgetDescriptor()java.lang.ObjectgetDestination()java.lang.StringgetEndpoint()java.lang.StringgetEndpointServer()longgetEntryTime()java.lang.StringgetHighWaterMark()longgetIdleTime()intgetMetadataRequestTimeout()intgetProcessRequestTimeout()java.lang.StringgetReplyToEndpoint()java.lang.StringgetSerializer()java.lang.StringgetServerURI()ServiceInfogetServiceInfo()intgetShadowPoolSize()intgetStatus()booleanhasNoConsumers()voidinitialize()booleanisCasMultiplier()booleanisFinal()booleanisFreeCasEndpoint()booleanisInitialized()booleanisOpen()booleanisRegisteredWithParent()booleanisRemote()booleanisReplyEndpoint()booleanisRetryEnabled()booleanisTempReplyDestination()booleanisWaitingForResponse()booleanprocessParentLast()booleanremove()booleanreplyDestinationFailed()voidsetCommand(int aCommand)voidsetCompletedProcessingCollection(boolean completed)voidsetConcurrentReplyConsumers(int aConsumerCount)voidsetConcurrentRequestConsumers(int aConsumerCount)voidsetController(AnalysisEngineController aController)voidsetDelegateKey(java.lang.String aDelegateKey)voidsetDescriptor(java.lang.String aDescriptor)voidsetDestination(java.lang.Object aDestination)voidsetEndpoint(java.lang.String endpoint)voidsetEndpointServer(java.lang.String anEndpointServer)voidsetFinal(boolean isFinal)voidsetFreeCasEndpoint(boolean trueOrFalse)voidsetHighWaterMark(java.lang.String aHighWaterMark)voidsetIdleTime(long anIdleTime)voidsetInitialFsHeapSize(int aHeapSize)voidsetInitialized(boolean initialized)voidsetIsCasMultiplier(boolean trueORfalse)voidsetMetadataRequestTimeout(int metadataRequestTimeout)voidsetNoConsumers(boolean trueOrFalse)voidsetProcessParentLast(boolean parentLast)voidsetProcessRequestTimeout(int processRequestTimeout)voidsetRegisteredWithParent()voidsetRemote(boolean aRemote)voidsetRemove(boolean removeIt)voidsetReplyDestinationFailed()voidsetReplyEndpoint(boolean tORf)voidsetSerializer(java.lang.String aSerializer)voidsetServerURI(java.lang.String serverURI)voidsetShadowCasPoolSize(int aPoolSize)voidsetStatus(int aStatus)voidsetTempReplyDestination(boolean isTempReplyDestination)voidsetWaitingForResponse(boolean isWaiting)voidstartCheckpointTimer()voidstartCollectionProcessCompleteTimer()voidstartMetadataRequestTimer()voidstartProcessRequestTimer(java.lang.String aCasReferenceId)
-
-
-
Field Detail
-
OK
static final int OK
- See Also:
- Constant Field Values
-
FAILED
static final int FAILED
- See Also:
- Constant Field Values
-
DISABLED
static final int DISABLED
- See Also:
- Constant Field Values
-
-
Method Detail
-
getMetadataRequestTimeout
int getMetadataRequestTimeout()
-
setController
void setController(AnalysisEngineController aController)
-
startCheckpointTimer
void startCheckpointTimer()
-
getCheckpointTimer
long getCheckpointTimer()
-
isRetryEnabled
boolean isRetryEnabled()
-
setMetadataRequestTimeout
void setMetadataRequestTimeout(int metadataRequestTimeout)
-
getProcessRequestTimeout
int getProcessRequestTimeout()
-
setReplyEndpoint
void setReplyEndpoint(boolean tORf)
-
isReplyEndpoint
boolean isReplyEndpoint()
-
setProcessRequestTimeout
void setProcessRequestTimeout(int processRequestTimeout)
-
completedProcessingCollection
boolean completedProcessingCollection()
-
setCompletedProcessingCollection
void setCompletedProcessingCollection(boolean completed)
-
setNoConsumers
void setNoConsumers(boolean trueOrFalse)
-
hasNoConsumers
boolean hasNoConsumers()
-
isInitialized
boolean isInitialized()
-
setInitialized
void setInitialized(boolean initialized)
-
getEndpoint
java.lang.String getEndpoint()
-
isFinal
boolean isFinal()
-
setFinal
void setFinal(boolean isFinal)
-
getEntryTime
long getEntryTime()
-
setEndpoint
void setEndpoint(java.lang.String endpoint)
-
getServerURI
java.lang.String getServerURI()
-
setServerURI
void setServerURI(java.lang.String serverURI)
-
startMetadataRequestTimer
void startMetadataRequestTimer()
-
startCollectionProcessCompleteTimer
void startCollectionProcessCompleteTimer()
-
startProcessRequestTimer
void startProcessRequestTimer(java.lang.String aCasReferenceId)
-
cancelTimer
void cancelTimer()
-
isWaitingForResponse
boolean isWaitingForResponse()
-
setWaitingForResponse
void setWaitingForResponse(boolean isWaiting)
-
initialize
void initialize() throws AsynchAEException- Throws:
AsynchAEException
-
setDescriptor
void setDescriptor(java.lang.String aDescriptor)
-
getDescriptor
java.lang.String getDescriptor()
-
setRemote
void setRemote(boolean aRemote)
-
getReplyToEndpoint
java.lang.String getReplyToEndpoint()
-
isRemote
boolean isRemote()
-
getSerializer
java.lang.String getSerializer()
-
close
void close()
-
isOpen
boolean isOpen()
-
setHighWaterMark
void setHighWaterMark(java.lang.String aHighWaterMark)
-
getHighWaterMark
java.lang.String getHighWaterMark()
-
remove
boolean remove()
-
setRemove
void setRemove(boolean removeIt)
-
isCasMultiplier
boolean isCasMultiplier()
-
setIsCasMultiplier
void setIsCasMultiplier(boolean trueORfalse)
-
setShadowCasPoolSize
void setShadowCasPoolSize(int aPoolSize)
-
getShadowPoolSize
int getShadowPoolSize()
-
getServiceInfo
ServiceInfo getServiceInfo()
-
getDestination
java.lang.Object getDestination()
-
setDestination
void setDestination(java.lang.Object aDestination)
-
setCommand
void setCommand(int aCommand)
-
getCommand
int getCommand()
-
setRegisteredWithParent
void setRegisteredWithParent()
-
isRegisteredWithParent
boolean isRegisteredWithParent()
-
setInitialFsHeapSize
void setInitialFsHeapSize(int aHeapSize)
-
setTempReplyDestination
void setTempReplyDestination(boolean isTempReplyDestination)
-
isTempReplyDestination
boolean isTempReplyDestination()
-
setReplyDestinationFailed
void setReplyDestinationFailed()
-
replyDestinationFailed
boolean replyDestinationFailed()
-
setIdleTime
void setIdleTime(long anIdleTime)
-
getIdleTime
long getIdleTime()
-
setEndpointServer
void setEndpointServer(java.lang.String anEndpointServer)
-
getEndpointServer
java.lang.String getEndpointServer()
-
setConcurrentRequestConsumers
void setConcurrentRequestConsumers(int aConsumerCount)
-
getConcurrentRequestConsumers
int getConcurrentRequestConsumers()
-
setConcurrentReplyConsumers
void setConcurrentReplyConsumers(int aConsumerCount)
-
getConcurrentReplyConsumers
int getConcurrentReplyConsumers()
-
setSerializer
void setSerializer(java.lang.String aSerializer)
-
setStatus
void setStatus(int aStatus)
-
getStatus
int getStatus()
-
setDelegateKey
void setDelegateKey(java.lang.String aDelegateKey)
-
getDelegateKey
java.lang.String getDelegateKey()
-
setProcessParentLast
void setProcessParentLast(boolean parentLast)
-
processParentLast
boolean processParentLast()
-
setFreeCasEndpoint
void setFreeCasEndpoint(boolean trueOrFalse)
-
isFreeCasEndpoint
boolean isFreeCasEndpoint()
-
-