Package org.apache.uima.aae.controller
Interface Endpoint
- All Known Implementing Classes:
Endpoint_impl
public interface Endpoint
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
close()
boolean
long
int
int
int
long
long
int
int
int
int
boolean
void
boolean
boolean
isFinal()
boolean
boolean
boolean
isOpen()
boolean
boolean
isRemote()
boolean
boolean
boolean
boolean
boolean
boolean
remove()
boolean
void
setCommand
(int aCommand) void
setCompletedProcessingCollection
(boolean completed) void
setConcurrentReplyConsumers
(int aConsumerCount) void
setConcurrentRequestConsumers
(int aConsumerCount) void
setController
(AnalysisEngineController aController) void
setDelegateKey
(String aDelegateKey) void
setDescriptor
(String aDescriptor) void
setDestination
(Object aDestination) void
setEndpoint
(String endpoint) void
setEndpointServer
(String anEndpointServer) void
setFinal
(boolean isFinal) void
setFreeCasEndpoint
(boolean trueOrFalse) void
setHighWaterMark
(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
void
setRemote
(boolean aRemote) void
setRemove
(boolean removeIt) void
void
setReplyEndpoint
(boolean tORf) void
setSerializer
(String aSerializer) void
setServerURI
(String serverURI) void
setShadowCasPoolSize
(int aPoolSize) void
setStatus
(int aStatus) void
setTempReplyDestination
(boolean isTempReplyDestination) void
setWaitingForResponse
(boolean isWaiting) void
void
void
void
startProcessRequestTimer
(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()
-