Package org.apache.uima.aae.controller
Class Endpoint_impl
- java.lang.Object
-
- org.apache.uima.aae.controller.Endpoint_impl
-
-
Constructor Summary
Constructors Constructor Description Endpoint_impl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancelTimer()
java.lang.Object
clone()
void
close()
boolean
completedProcessingCollection()
long
getCheckpointTimer()
int
getCollectionProcessCompleteTimeout()
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
setCollectionProcessCompleteTimeout(int cpcTimeout)
void
setCommand(int command)
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 idleTime)
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 rm)
void
setReplyDestinationFailed()
void
setReplyEndpoint(boolean tORf)
void
setReplyToEndpoint(java.lang.String anEndpointName)
void
setRetryEnabled(boolean retryEnabled)
void
setSerializer(java.lang.String serializer)
void
setServerURI(java.lang.String aServerURI)
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)
java.lang.String
toString()
-
-
-
Method Detail
-
setFreeCasEndpoint
public void setFreeCasEndpoint(boolean trueOrFalse)
- Specified by:
setFreeCasEndpoint
in interfaceEndpoint
-
isFreeCasEndpoint
public boolean isFreeCasEndpoint()
- Specified by:
isFreeCasEndpoint
in interfaceEndpoint
-
setProcessParentLast
public void setProcessParentLast(boolean parentLast)
- Specified by:
setProcessParentLast
in interfaceEndpoint
-
processParentLast
public boolean processParentLast()
- Specified by:
processParentLast
in interfaceEndpoint
-
getCommand
public int getCommand()
- Specified by:
getCommand
in interfaceEndpoint
-
setCommand
public void setCommand(int command)
- Specified by:
setCommand
in interfaceEndpoint
-
setNoConsumers
public void setNoConsumers(boolean trueOrFalse)
- Specified by:
setNoConsumers
in interfaceEndpoint
-
setReplyEndpoint
public void setReplyEndpoint(boolean tORf)
- Specified by:
setReplyEndpoint
in interfaceEndpoint
-
isReplyEndpoint
public boolean isReplyEndpoint()
- Specified by:
isReplyEndpoint
in interfaceEndpoint
-
hasNoConsumers
public boolean hasNoConsumers()
- Specified by:
hasNoConsumers
in interfaceEndpoint
-
getReplyToEndpoint
public java.lang.String getReplyToEndpoint()
- Specified by:
getReplyToEndpoint
in interfaceEndpoint
-
setReplyToEndpoint
public void setReplyToEndpoint(java.lang.String anEndpointName)
-
completedProcessingCollection
public boolean completedProcessingCollection()
- Specified by:
completedProcessingCollection
in interfaceEndpoint
-
setCompletedProcessingCollection
public void setCompletedProcessingCollection(boolean completed)
- Specified by:
setCompletedProcessingCollection
in interfaceEndpoint
-
setHighWaterMark
public void setHighWaterMark(java.lang.String aHighWaterMark)
- Specified by:
setHighWaterMark
in interfaceEndpoint
-
getHighWaterMark
public java.lang.String getHighWaterMark()
- Specified by:
getHighWaterMark
in interfaceEndpoint
-
isRetryEnabled
public boolean isRetryEnabled()
- Specified by:
isRetryEnabled
in interfaceEndpoint
-
setRetryEnabled
public void setRetryEnabled(boolean retryEnabled)
-
setController
public void setController(AnalysisEngineController aController)
- Specified by:
setController
in interfaceEndpoint
-
startCheckpointTimer
public void startCheckpointTimer()
- Specified by:
startCheckpointTimer
in interfaceEndpoint
-
getCheckpointTimer
public long getCheckpointTimer()
- Specified by:
getCheckpointTimer
in interfaceEndpoint
-
getEntryTime
public long getEntryTime()
- Specified by:
getEntryTime
in interfaceEndpoint
-
clone
public java.lang.Object clone()
- Overrides:
clone
in classjava.lang.Object
-
getSerializer
public java.lang.String getSerializer()
- Specified by:
getSerializer
in interfaceEndpoint
-
setSerializer
public void setSerializer(java.lang.String serializer)
- Specified by:
setSerializer
in interfaceEndpoint
-
getMetadataRequestTimeout
public int getMetadataRequestTimeout()
- Specified by:
getMetadataRequestTimeout
in interfaceEndpoint
-
setMetadataRequestTimeout
public void setMetadataRequestTimeout(int metadataRequestTimeout)
- Specified by:
setMetadataRequestTimeout
in interfaceEndpoint
-
getProcessRequestTimeout
public int getProcessRequestTimeout()
- Specified by:
getProcessRequestTimeout
in interfaceEndpoint
-
setProcessRequestTimeout
public void setProcessRequestTimeout(int processRequestTimeout)
- Specified by:
setProcessRequestTimeout
in interfaceEndpoint
-
setCollectionProcessCompleteTimeout
public void setCollectionProcessCompleteTimeout(int cpcTimeout)
-
getCollectionProcessCompleteTimeout
public int getCollectionProcessCompleteTimeout()
-
isInitialized
public boolean isInitialized()
- Specified by:
isInitialized
in interfaceEndpoint
-
setInitialized
public void setInitialized(boolean initialized)
- Specified by:
setInitialized
in interfaceEndpoint
-
getEndpoint
public java.lang.String getEndpoint()
- Specified by:
getEndpoint
in interfaceEndpoint
-
setEndpoint
public void setEndpoint(java.lang.String endpoint)
- Specified by:
setEndpoint
in interfaceEndpoint
-
getServerURI
public java.lang.String getServerURI()
- Specified by:
getServerURI
in interfaceEndpoint
-
setServerURI
public void setServerURI(java.lang.String aServerURI)
- Specified by:
setServerURI
in interfaceEndpoint
-
setWaitingForResponse
public void setWaitingForResponse(boolean isWaiting)
- Specified by:
setWaitingForResponse
in interfaceEndpoint
-
getServiceInfo
public ServiceInfo getServiceInfo()
- Specified by:
getServiceInfo
in interfaceEndpoint
-
startProcessRequestTimer
public void startProcessRequestTimer(java.lang.String aCasReferenceId)
- Specified by:
startProcessRequestTimer
in interfaceEndpoint
-
startMetadataRequestTimer
public void startMetadataRequestTimer()
- Specified by:
startMetadataRequestTimer
in interfaceEndpoint
-
startCollectionProcessCompleteTimer
public void startCollectionProcessCompleteTimer()
- Specified by:
startCollectionProcessCompleteTimer
in interfaceEndpoint
-
cancelTimer
public void cancelTimer()
- Specified by:
cancelTimer
in interfaceEndpoint
-
isWaitingForResponse
public boolean isWaitingForResponse()
- Specified by:
isWaitingForResponse
in interfaceEndpoint
-
getDescriptor
public java.lang.String getDescriptor()
- Specified by:
getDescriptor
in interfaceEndpoint
-
setDescriptor
public void setDescriptor(java.lang.String aDescriptor)
- Specified by:
setDescriptor
in interfaceEndpoint
-
initialize
public void initialize() throws AsynchAEException
- Specified by:
initialize
in interfaceEndpoint
- Throws:
AsynchAEException
-
isCasMultiplier
public boolean isCasMultiplier()
- Specified by:
isCasMultiplier
in interfaceEndpoint
-
setIsCasMultiplier
public void setIsCasMultiplier(boolean trueORfalse)
- Specified by:
setIsCasMultiplier
in interfaceEndpoint
-
setShadowCasPoolSize
public void setShadowCasPoolSize(int aPoolSize)
- Specified by:
setShadowCasPoolSize
in interfaceEndpoint
-
getShadowPoolSize
public int getShadowPoolSize()
- Specified by:
getShadowPoolSize
in interfaceEndpoint
-
getDestination
public java.lang.Object getDestination()
- Specified by:
getDestination
in interfaceEndpoint
-
setDestination
public void setDestination(java.lang.Object aDestination)
- Specified by:
setDestination
in interfaceEndpoint
-
setRegisteredWithParent
public void setRegisteredWithParent()
- Specified by:
setRegisteredWithParent
in interfaceEndpoint
-
isRegisteredWithParent
public boolean isRegisteredWithParent()
- Specified by:
isRegisteredWithParent
in interfaceEndpoint
-
setInitialFsHeapSize
public void setInitialFsHeapSize(int aHeapSize)
- Specified by:
setInitialFsHeapSize
in interfaceEndpoint
-
setTempReplyDestination
public void setTempReplyDestination(boolean isTempReplyDestination)
- Specified by:
setTempReplyDestination
in interfaceEndpoint
-
isTempReplyDestination
public boolean isTempReplyDestination()
- Specified by:
isTempReplyDestination
in interfaceEndpoint
-
setReplyDestinationFailed
public void setReplyDestinationFailed()
- Specified by:
setReplyDestinationFailed
in interfaceEndpoint
-
replyDestinationFailed
public boolean replyDestinationFailed()
- Specified by:
replyDestinationFailed
in interfaceEndpoint
-
getIdleTime
public long getIdleTime()
- Specified by:
getIdleTime
in interfaceEndpoint
-
setIdleTime
public void setIdleTime(long idleTime)
- Specified by:
setIdleTime
in interfaceEndpoint
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
setEndpointServer
public void setEndpointServer(java.lang.String anEndpointServer)
- Specified by:
setEndpointServer
in interfaceEndpoint
-
getEndpointServer
public java.lang.String getEndpointServer()
- Specified by:
getEndpointServer
in interfaceEndpoint
-
setConcurrentRequestConsumers
public void setConcurrentRequestConsumers(int aConsumerCount)
- Specified by:
setConcurrentRequestConsumers
in interfaceEndpoint
-
getConcurrentRequestConsumers
public int getConcurrentRequestConsumers()
- Specified by:
getConcurrentRequestConsumers
in interfaceEndpoint
-
setConcurrentReplyConsumers
public void setConcurrentReplyConsumers(int aConsumerCount)
- Specified by:
setConcurrentReplyConsumers
in interfaceEndpoint
-
getConcurrentReplyConsumers
public int getConcurrentReplyConsumers()
- Specified by:
getConcurrentReplyConsumers
in interfaceEndpoint
-
setDelegateKey
public void setDelegateKey(java.lang.String aDelegateKey)
- Specified by:
setDelegateKey
in interfaceEndpoint
-
getDelegateKey
public java.lang.String getDelegateKey()
- Specified by:
getDelegateKey
in interfaceEndpoint
-
-