Package org.apache.uima.aae.controller
Class Endpoint_impl
java.lang.Object
org.apache.uima.aae.controller.Endpoint_impl
-
Field Summary
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclone()voidclose()booleanlongintintintintlonglongintintintintbooleanvoidbooleanbooleanisFinal()booleanbooleanbooleanisOpen()booleanbooleanisRemote()booleanbooleanbooleanbooleanbooleanbooleanremove()booleanvoidsetCollectionProcessCompleteTimeout(int cpcTimeout) voidsetCommand(int command) voidsetCompletedProcessingCollection(boolean completed) voidsetConcurrentReplyConsumers(int aConsumerCount) voidsetConcurrentRequestConsumers(int aConsumerCount) voidsetController(AnalysisEngineController aController) voidsetDelegateKey(String aDelegateKey) voidsetDescriptor(String aDescriptor) voidsetDestination(Object aDestination) voidsetEndpoint(String endpoint) voidsetEndpointServer(String anEndpointServer) voidsetFinal(boolean isFinal) voidsetFreeCasEndpoint(boolean trueOrFalse) voidsetHighWaterMark(String aHighWaterMark) voidsetIdleTime(long idleTime) voidsetInitialFsHeapSize(int aHeapSize) voidsetInitialized(boolean initialized) voidsetIsCasMultiplier(boolean trueORfalse) voidsetMetadataRequestTimeout(int metadataRequestTimeout) voidsetNoConsumers(boolean trueOrFalse) voidsetProcessParentLast(boolean parentLast) voidsetProcessRequestTimeout(int processRequestTimeout) voidvoidsetRemote(boolean aRemote) voidsetRemove(boolean rm) voidvoidsetReplyEndpoint(boolean tORf) voidsetReplyToEndpoint(String anEndpointName) voidsetRetryEnabled(boolean retryEnabled) voidsetSerializer(String serializer) voidsetServerURI(String aServerURI) voidsetShadowCasPoolSize(int aPoolSize) voidsetStatus(int aStatus) voidsetTempReplyDestination(boolean isTempReplyDestination) voidsetWaitingForResponse(boolean isWaiting) voidvoidvoidvoidstartProcessRequestTimer(String aCasReferenceId) toString()
-
Constructor Details
-
Endpoint_impl
public Endpoint_impl()
-
-
Method Details
-
setFreeCasEndpoint
public void setFreeCasEndpoint(boolean trueOrFalse) - Specified by:
setFreeCasEndpointin interfaceEndpoint
-
isFreeCasEndpoint
public boolean isFreeCasEndpoint()- Specified by:
isFreeCasEndpointin interfaceEndpoint
-
setProcessParentLast
public void setProcessParentLast(boolean parentLast) - Specified by:
setProcessParentLastin interfaceEndpoint
-
processParentLast
public boolean processParentLast()- Specified by:
processParentLastin interfaceEndpoint
-
getCommand
public int getCommand()- Specified by:
getCommandin interfaceEndpoint
-
setCommand
public void setCommand(int command) - Specified by:
setCommandin interfaceEndpoint
-
setNoConsumers
public void setNoConsumers(boolean trueOrFalse) - Specified by:
setNoConsumersin interfaceEndpoint
-
setReplyEndpoint
public void setReplyEndpoint(boolean tORf) - Specified by:
setReplyEndpointin interfaceEndpoint
-
isReplyEndpoint
public boolean isReplyEndpoint()- Specified by:
isReplyEndpointin interfaceEndpoint
-
remove
public boolean remove() -
setRemove
public void setRemove(boolean rm) -
hasNoConsumers
public boolean hasNoConsumers()- Specified by:
hasNoConsumersin interfaceEndpoint
-
getReplyToEndpoint
- Specified by:
getReplyToEndpointin interfaceEndpoint
-
setReplyToEndpoint
-
completedProcessingCollection
public boolean completedProcessingCollection()- Specified by:
completedProcessingCollectionin interfaceEndpoint
-
setCompletedProcessingCollection
public void setCompletedProcessingCollection(boolean completed) - Specified by:
setCompletedProcessingCollectionin interfaceEndpoint
-
setHighWaterMark
- Specified by:
setHighWaterMarkin interfaceEndpoint
-
getHighWaterMark
- Specified by:
getHighWaterMarkin interfaceEndpoint
-
isRetryEnabled
public boolean isRetryEnabled()- Specified by:
isRetryEnabledin interfaceEndpoint
-
setRetryEnabled
public void setRetryEnabled(boolean retryEnabled) -
setController
- Specified by:
setControllerin interfaceEndpoint
-
startCheckpointTimer
public void startCheckpointTimer()- Specified by:
startCheckpointTimerin interfaceEndpoint
-
getCheckpointTimer
public long getCheckpointTimer()- Specified by:
getCheckpointTimerin interfaceEndpoint
-
getEntryTime
public long getEntryTime()- Specified by:
getEntryTimein interfaceEndpoint
-
clone
-
getSerializer
- Specified by:
getSerializerin interfaceEndpoint
-
isFinal
public boolean isFinal() -
setFinal
public void setFinal(boolean isFinal) -
setSerializer
- Specified by:
setSerializerin interfaceEndpoint
-
getMetadataRequestTimeout
public int getMetadataRequestTimeout()- Specified by:
getMetadataRequestTimeoutin interfaceEndpoint
-
setMetadataRequestTimeout
public void setMetadataRequestTimeout(int metadataRequestTimeout) - Specified by:
setMetadataRequestTimeoutin interfaceEndpoint
-
getProcessRequestTimeout
public int getProcessRequestTimeout()- Specified by:
getProcessRequestTimeoutin interfaceEndpoint
-
setProcessRequestTimeout
public void setProcessRequestTimeout(int processRequestTimeout) - Specified by:
setProcessRequestTimeoutin interfaceEndpoint
-
setCollectionProcessCompleteTimeout
public void setCollectionProcessCompleteTimeout(int cpcTimeout) -
getCollectionProcessCompleteTimeout
public int getCollectionProcessCompleteTimeout() -
isInitialized
public boolean isInitialized()- Specified by:
isInitializedin interfaceEndpoint
-
setInitialized
public void setInitialized(boolean initialized) - Specified by:
setInitializedin interfaceEndpoint
-
getEndpoint
- Specified by:
getEndpointin interfaceEndpoint
-
setEndpoint
- Specified by:
setEndpointin interfaceEndpoint
-
getServerURI
- Specified by:
getServerURIin interfaceEndpoint
-
setServerURI
- Specified by:
setServerURIin interfaceEndpoint
-
setWaitingForResponse
public void setWaitingForResponse(boolean isWaiting) - Specified by:
setWaitingForResponsein interfaceEndpoint
-
getServiceInfo
- Specified by:
getServiceInfoin interfaceEndpoint
-
startProcessRequestTimer
- Specified by:
startProcessRequestTimerin interfaceEndpoint
-
startMetadataRequestTimer
public void startMetadataRequestTimer()- Specified by:
startMetadataRequestTimerin interfaceEndpoint
-
startCollectionProcessCompleteTimer
public void startCollectionProcessCompleteTimer()- Specified by:
startCollectionProcessCompleteTimerin interfaceEndpoint
-
cancelTimer
public void cancelTimer()- Specified by:
cancelTimerin interfaceEndpoint
-
isWaitingForResponse
public boolean isWaitingForResponse()- Specified by:
isWaitingForResponsein interfaceEndpoint
-
isRemote
public boolean isRemote() -
setRemote
public void setRemote(boolean aRemote) -
getDescriptor
- Specified by:
getDescriptorin interfaceEndpoint
-
setDescriptor
- Specified by:
setDescriptorin interfaceEndpoint
-
initialize
- Specified by:
initializein interfaceEndpoint- Throws:
AsynchAEException
-
isOpen
public boolean isOpen() -
close
public void close() -
isCasMultiplier
public boolean isCasMultiplier()- Specified by:
isCasMultiplierin interfaceEndpoint
-
setIsCasMultiplier
public void setIsCasMultiplier(boolean trueORfalse) - Specified by:
setIsCasMultiplierin interfaceEndpoint
-
setShadowCasPoolSize
public void setShadowCasPoolSize(int aPoolSize) - Specified by:
setShadowCasPoolSizein interfaceEndpoint
-
getShadowPoolSize
public int getShadowPoolSize()- Specified by:
getShadowPoolSizein interfaceEndpoint
-
getDestination
- Specified by:
getDestinationin interfaceEndpoint
-
setDestination
- Specified by:
setDestinationin interfaceEndpoint
-
setRegisteredWithParent
public void setRegisteredWithParent()- Specified by:
setRegisteredWithParentin interfaceEndpoint
-
isRegisteredWithParent
public boolean isRegisteredWithParent()- Specified by:
isRegisteredWithParentin interfaceEndpoint
-
setInitialFsHeapSize
public void setInitialFsHeapSize(int aHeapSize) - Specified by:
setInitialFsHeapSizein interfaceEndpoint
-
setTempReplyDestination
public void setTempReplyDestination(boolean isTempReplyDestination) - Specified by:
setTempReplyDestinationin interfaceEndpoint
-
isTempReplyDestination
public boolean isTempReplyDestination()- Specified by:
isTempReplyDestinationin interfaceEndpoint
-
setReplyDestinationFailed
public void setReplyDestinationFailed()- Specified by:
setReplyDestinationFailedin interfaceEndpoint
-
replyDestinationFailed
public boolean replyDestinationFailed()- Specified by:
replyDestinationFailedin interfaceEndpoint
-
getIdleTime
public long getIdleTime()- Specified by:
getIdleTimein interfaceEndpoint
-
setIdleTime
public void setIdleTime(long idleTime) - Specified by:
setIdleTimein interfaceEndpoint
-
toString
-
setEndpointServer
- Specified by:
setEndpointServerin interfaceEndpoint
-
getEndpointServer
- Specified by:
getEndpointServerin interfaceEndpoint
-
setConcurrentRequestConsumers
public void setConcurrentRequestConsumers(int aConsumerCount) - Specified by:
setConcurrentRequestConsumersin interfaceEndpoint
-
getConcurrentRequestConsumers
public int getConcurrentRequestConsumers()- Specified by:
getConcurrentRequestConsumersin interfaceEndpoint
-
setConcurrentReplyConsumers
public void setConcurrentReplyConsumers(int aConsumerCount) - Specified by:
setConcurrentReplyConsumersin interfaceEndpoint
-
getConcurrentReplyConsumers
public int getConcurrentReplyConsumers()- Specified by:
getConcurrentReplyConsumersin interfaceEndpoint
-
setStatus
public void setStatus(int aStatus) -
getStatus
public int getStatus() -
setDelegateKey
- Specified by:
setDelegateKeyin interfaceEndpoint
-
getDelegateKey
- Specified by:
getDelegateKeyin interfaceEndpoint
-