Package org.apache.uima.aae.controller
Interface Endpoint
- All Known Implementing Classes:
Endpoint_impl
public interface Endpoint
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidclose()booleanlongintintintlonglongintintintintbooleanvoidbooleanbooleanisFinal()booleanbooleanbooleanisOpen()booleanbooleanisRemote()booleanbooleanbooleanbooleanbooleanbooleanremove()booleanvoidsetCommand(int aCommand) 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 anIdleTime) 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 removeIt) voidvoidsetReplyEndpoint(boolean tORf) voidsetSerializer(String aSerializer) voidsetServerURI(String serverURI) voidsetShadowCasPoolSize(int aPoolSize) voidsetStatus(int aStatus) voidsetTempReplyDestination(boolean isTempReplyDestination) voidsetWaitingForResponse(boolean isWaiting) voidvoidvoidvoidstartProcessRequestTimer(String aCasReferenceId)
-
Field Details
-
OK
static final int OK- See Also:
-
FAILED
static final int FAILED- See Also:
-
DISABLED
static final int DISABLED- See Also:
-
-
Method Details
-
getMetadataRequestTimeout
int getMetadataRequestTimeout() -
setController
-
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
String getEndpoint() -
isFinal
boolean isFinal() -
setFinal
void setFinal(boolean isFinal) -
getEntryTime
long getEntryTime() -
setEndpoint
-
getServerURI
String getServerURI() -
setServerURI
-
startMetadataRequestTimer
void startMetadataRequestTimer() -
startCollectionProcessCompleteTimer
void startCollectionProcessCompleteTimer() -
startProcessRequestTimer
-
cancelTimer
void cancelTimer() -
isWaitingForResponse
boolean isWaitingForResponse() -
setWaitingForResponse
void setWaitingForResponse(boolean isWaiting) -
initialize
- Throws:
AsynchAEException
-
setDescriptor
-
getDescriptor
String getDescriptor() -
setRemote
void setRemote(boolean aRemote) -
getReplyToEndpoint
String getReplyToEndpoint() -
isRemote
boolean isRemote() -
getSerializer
String getSerializer() -
close
void close() -
isOpen
boolean isOpen() -
setHighWaterMark
-
getHighWaterMark
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
Object getDestination() -
setDestination
-
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
-
getEndpointServer
String getEndpointServer() -
setConcurrentRequestConsumers
void setConcurrentRequestConsumers(int aConsumerCount) -
getConcurrentRequestConsumers
int getConcurrentRequestConsumers() -
setConcurrentReplyConsumers
void setConcurrentReplyConsumers(int aConsumerCount) -
getConcurrentReplyConsumers
int getConcurrentReplyConsumers() -
setSerializer
-
setStatus
void setStatus(int aStatus) -
getStatus
int getStatus() -
setDelegateKey
-
getDelegateKey
String getDelegateKey() -
setProcessParentLast
void setProcessParentLast(boolean parentLast) -
processParentLast
boolean processParentLast() -
setFreeCasEndpoint
void setFreeCasEndpoint(boolean trueOrFalse) -
isFreeCasEndpoint
boolean isFreeCasEndpoint()
-