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 void
cancelTimer()
void
close()
boolean
completedProcessingCollection()
long
getCheckpointTimer()
int
getCommand()
int
getConcurrentReplyConsumers()
int
getConcurrentRequestConsumers()
java.lang.String
getDelegateKey()
java.lang.String
getDescriptor()
java.lang.Object
getDestination()
java.lang.String
getEndpoint()
java.lang.String
getEndpointServer()
long
getEntryTime()
java.lang.String
getHighWaterMark()
long
getIdleTime()
int
getMetadataRequestTimeout()
int
getProcessRequestTimeout()
java.lang.String
getReplyToEndpoint()
java.lang.String
getSerializer()
java.lang.String
getServerURI()
ServiceInfo
getServiceInfo()
int
getShadowPoolSize()
int
getStatus()
boolean
hasNoConsumers()
void
initialize()
boolean
isCasMultiplier()
boolean
isFinal()
boolean
isFreeCasEndpoint()
boolean
isInitialized()
boolean
isOpen()
boolean
isRegisteredWithParent()
boolean
isRemote()
boolean
isReplyEndpoint()
boolean
isRetryEnabled()
boolean
isTempReplyDestination()
boolean
isWaitingForResponse()
boolean
processParentLast()
boolean
remove()
boolean
replyDestinationFailed()
void
setCommand(int aCommand)
void
setCompletedProcessingCollection(boolean completed)
void
setConcurrentReplyConsumers(int aConsumerCount)
void
setConcurrentRequestConsumers(int aConsumerCount)
void
setController(AnalysisEngineController aController)
void
setDelegateKey(java.lang.String aDelegateKey)
void
setDescriptor(java.lang.String aDescriptor)
void
setDestination(java.lang.Object aDestination)
void
setEndpoint(java.lang.String endpoint)
void
setEndpointServer(java.lang.String anEndpointServer)
void
setFinal(boolean isFinal)
void
setFreeCasEndpoint(boolean trueOrFalse)
void
setHighWaterMark(java.lang.String aHighWaterMark)
void
setIdleTime(long anIdleTime)
void
setInitialFsHeapSize(int aHeapSize)
void
setInitialized(boolean initialized)
void
setIsCasMultiplier(boolean trueORfalse)
void
setMetadataRequestTimeout(int metadataRequestTimeout)
void
setNoConsumers(boolean trueOrFalse)
void
setProcessParentLast(boolean parentLast)
void
setProcessRequestTimeout(int processRequestTimeout)
void
setRegisteredWithParent()
void
setRemote(boolean aRemote)
void
setRemove(boolean removeIt)
void
setReplyDestinationFailed()
void
setReplyEndpoint(boolean tORf)
void
setSerializer(java.lang.String aSerializer)
void
setServerURI(java.lang.String serverURI)
void
setShadowCasPoolSize(int aPoolSize)
void
setStatus(int aStatus)
void
setTempReplyDestination(boolean isTempReplyDestination)
void
setWaitingForResponse(boolean isWaiting)
void
startCheckpointTimer()
void
startCollectionProcessCompleteTimer()
void
startMetadataRequestTimer()
void
startProcessRequestTimer(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()
-
-