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 TypeMethodDescriptionvoid
clone()
void
close()
boolean
long
int
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
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
(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 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
void
setRemote
(boolean aRemote) void
setRemove
(boolean rm) void
void
setReplyEndpoint
(boolean tORf) void
setReplyToEndpoint
(String anEndpointName) void
setRetryEnabled
(boolean retryEnabled) void
setSerializer
(String serializer) void
setServerURI
(String aServerURI) void
setShadowCasPoolSize
(int aPoolSize) void
setStatus
(int aStatus) void
setTempReplyDestination
(boolean isTempReplyDestination) void
setWaitingForResponse
(boolean isWaiting) void
void
void
void
startProcessRequestTimer
(String aCasReferenceId) toString()
-
Constructor Details
-
Endpoint_impl
public Endpoint_impl()
-
-
Method Details
-
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
-
remove
public boolean remove() -
setRemove
public void setRemove(boolean rm) -
hasNoConsumers
public boolean hasNoConsumers()- Specified by:
hasNoConsumers
in interfaceEndpoint
-
getReplyToEndpoint
- Specified by:
getReplyToEndpoint
in interfaceEndpoint
-
setReplyToEndpoint
-
completedProcessingCollection
public boolean completedProcessingCollection()- Specified by:
completedProcessingCollection
in interfaceEndpoint
-
setCompletedProcessingCollection
public void setCompletedProcessingCollection(boolean completed) - Specified by:
setCompletedProcessingCollection
in interfaceEndpoint
-
setHighWaterMark
- Specified by:
setHighWaterMark
in interfaceEndpoint
-
getHighWaterMark
- Specified by:
getHighWaterMark
in interfaceEndpoint
-
isRetryEnabled
public boolean isRetryEnabled()- Specified by:
isRetryEnabled
in interfaceEndpoint
-
setRetryEnabled
public void setRetryEnabled(boolean retryEnabled) -
setController
- 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
-
getSerializer
- Specified by:
getSerializer
in interfaceEndpoint
-
isFinal
public boolean isFinal() -
setFinal
public void setFinal(boolean isFinal) -
setSerializer
- 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
- Specified by:
getEndpoint
in interfaceEndpoint
-
setEndpoint
- Specified by:
setEndpoint
in interfaceEndpoint
-
getServerURI
- Specified by:
getServerURI
in interfaceEndpoint
-
setServerURI
- Specified by:
setServerURI
in interfaceEndpoint
-
setWaitingForResponse
public void setWaitingForResponse(boolean isWaiting) - Specified by:
setWaitingForResponse
in interfaceEndpoint
-
getServiceInfo
- Specified by:
getServiceInfo
in interfaceEndpoint
-
startProcessRequestTimer
- 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
-
isRemote
public boolean isRemote() -
setRemote
public void setRemote(boolean aRemote) -
getDescriptor
- Specified by:
getDescriptor
in interfaceEndpoint
-
setDescriptor
- Specified by:
setDescriptor
in interfaceEndpoint
-
initialize
- Specified by:
initialize
in interfaceEndpoint
- Throws:
AsynchAEException
-
isOpen
public boolean isOpen() -
close
public void close() -
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
- Specified by:
getDestination
in interfaceEndpoint
-
setDestination
- 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
-
setEndpointServer
- Specified by:
setEndpointServer
in interfaceEndpoint
-
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
-
setStatus
public void setStatus(int aStatus) -
getStatus
public int getStatus() -
setDelegateKey
- Specified by:
setDelegateKey
in interfaceEndpoint
-
getDelegateKey
- Specified by:
getDelegateKey
in interfaceEndpoint
-