Package org.apache.uima.aae.controller

Class Endpoint_impl

java.lang.Object

org.apache.uima.aae.controller.Endpoint_impl

All Implemented Interfaces:

java.lang.Cloneable, Endpoint

public class Endpoint_impl
extends java.lang.Object
implements Endpoint, java.lang.Cloneable

Field Summary

Fields inherited from interface org.apache.uima.aae.controller.Endpoint

DISABLED, FAILED, OK

Constructor Summary

Constructors

Constructor	Description
Endpoint_impl()

Method Summary

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()

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Endpoint_impl

public Endpoint_impl()

Method Detail

setFreeCasEndpoint

public void setFreeCasEndpoint(boolean trueOrFalse)

Specified by:

setFreeCasEndpoint in interface Endpoint

isFreeCasEndpoint

public boolean isFreeCasEndpoint()

Specified by:

isFreeCasEndpoint in interface Endpoint

setProcessParentLast

public void setProcessParentLast(boolean parentLast)

Specified by:

setProcessParentLast in interface Endpoint

processParentLast

public boolean processParentLast()

Specified by:

processParentLast in interface Endpoint

getCommand

public int getCommand()

Specified by:

getCommand in interface Endpoint

setCommand

public void setCommand(int command)

Specified by:

setCommand in interface Endpoint

setNoConsumers

public void setNoConsumers(boolean trueOrFalse)

Specified by:

setNoConsumers in interface Endpoint

setReplyEndpoint

public void setReplyEndpoint(boolean tORf)

Specified by:

setReplyEndpoint in interface Endpoint

isReplyEndpoint

public boolean isReplyEndpoint()

Specified by:

isReplyEndpoint in interface Endpoint

remove

public boolean remove()

Specified by:

remove in interface Endpoint

setRemove

public void setRemove(boolean rm)

Specified by:

setRemove in interface Endpoint

hasNoConsumers

public boolean hasNoConsumers()

Specified by:

hasNoConsumers in interface Endpoint

getReplyToEndpoint

public java.lang.String getReplyToEndpoint()

Specified by:

getReplyToEndpoint in interface Endpoint

setReplyToEndpoint

public void setReplyToEndpoint(java.lang.String anEndpointName)

completedProcessingCollection

public boolean completedProcessingCollection()

Specified by:

completedProcessingCollection in interface Endpoint

setCompletedProcessingCollection

public void setCompletedProcessingCollection(boolean completed)

Specified by:

setCompletedProcessingCollection in interface Endpoint

setHighWaterMark

public void setHighWaterMark(java.lang.String aHighWaterMark)

Specified by:

setHighWaterMark in interface Endpoint

getHighWaterMark

public java.lang.String getHighWaterMark()

Specified by:

getHighWaterMark in interface Endpoint

isRetryEnabled

public boolean isRetryEnabled()

Specified by:

isRetryEnabled in interface Endpoint

setRetryEnabled

public void setRetryEnabled(boolean retryEnabled)

setController

public void setController(AnalysisEngineController aController)

Specified by:

setController in interface Endpoint

startCheckpointTimer

public void startCheckpointTimer()

Specified by:

startCheckpointTimer in interface Endpoint

getCheckpointTimer

public long getCheckpointTimer()

Specified by:

getCheckpointTimer in interface Endpoint

getEntryTime

public long getEntryTime()

Specified by:

getEntryTime in interface Endpoint

clone

public java.lang.Object clone()

Overrides:

clone in class java.lang.Object

getSerializer

public java.lang.String getSerializer()

Specified by:

getSerializer in interface Endpoint

isFinal

public boolean isFinal()

Specified by:

isFinal in interface Endpoint

setFinal

public void setFinal(boolean isFinal)

Specified by:

setFinal in interface Endpoint

setSerializer

public void setSerializer(java.lang.String serializer)

Specified by:

setSerializer in interface Endpoint

getMetadataRequestTimeout

public int getMetadataRequestTimeout()

Specified by:

getMetadataRequestTimeout in interface Endpoint

setMetadataRequestTimeout

public void setMetadataRequestTimeout(int metadataRequestTimeout)

Specified by:

setMetadataRequestTimeout in interface Endpoint

getProcessRequestTimeout

public int getProcessRequestTimeout()

Specified by:

getProcessRequestTimeout in interface Endpoint

setProcessRequestTimeout

public void setProcessRequestTimeout(int processRequestTimeout)

Specified by:

setProcessRequestTimeout in interface Endpoint

setCollectionProcessCompleteTimeout

public void setCollectionProcessCompleteTimeout(int cpcTimeout)

getCollectionProcessCompleteTimeout

public int getCollectionProcessCompleteTimeout()

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface Endpoint

setInitialized

public void setInitialized(boolean initialized)

Specified by:

setInitialized in interface Endpoint

getEndpoint

public java.lang.String getEndpoint()

Specified by:

getEndpoint in interface Endpoint

setEndpoint

public void setEndpoint(java.lang.String endpoint)

Specified by:

setEndpoint in interface Endpoint

getServerURI

public java.lang.String getServerURI()

Specified by:

getServerURI in interface Endpoint

setServerURI

public void setServerURI(java.lang.String aServerURI)

Specified by:

setServerURI in interface Endpoint

setWaitingForResponse

public void setWaitingForResponse(boolean isWaiting)

Specified by:

setWaitingForResponse in interface Endpoint

getServiceInfo

public ServiceInfo getServiceInfo()

Specified by:

getServiceInfo in interface Endpoint

startProcessRequestTimer

public void startProcessRequestTimer(java.lang.String aCasReferenceId)

Specified by:

startProcessRequestTimer in interface Endpoint

startMetadataRequestTimer

public void startMetadataRequestTimer()

Specified by:

startMetadataRequestTimer in interface Endpoint

startCollectionProcessCompleteTimer

public void startCollectionProcessCompleteTimer()

Specified by:

startCollectionProcessCompleteTimer in interface Endpoint

cancelTimer

public void cancelTimer()

Specified by:

cancelTimer in interface Endpoint

isWaitingForResponse

public boolean isWaitingForResponse()

Specified by:

isWaitingForResponse in interface Endpoint

isRemote

public boolean isRemote()

Specified by:

isRemote in interface Endpoint

setRemote

public void setRemote(boolean aRemote)

Specified by:

setRemote in interface Endpoint

getDescriptor

public java.lang.String getDescriptor()

Specified by:

getDescriptor in interface Endpoint

setDescriptor

public void setDescriptor(java.lang.String aDescriptor)

Specified by:

setDescriptor in interface Endpoint

initialize

public void initialize()
                throws AsynchAEException

Specified by:

initialize in interface Endpoint

Throws:

AsynchAEException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Endpoint

close

public void close()

Specified by:

close in interface Endpoint

isCasMultiplier

public boolean isCasMultiplier()

Specified by:

isCasMultiplier in interface Endpoint

setIsCasMultiplier

public void setIsCasMultiplier(boolean trueORfalse)

Specified by:

setIsCasMultiplier in interface Endpoint

setShadowCasPoolSize

public void setShadowCasPoolSize(int aPoolSize)

Specified by:

setShadowCasPoolSize in interface Endpoint

getShadowPoolSize

public int getShadowPoolSize()

Specified by:

getShadowPoolSize in interface Endpoint

getDestination

public java.lang.Object getDestination()

Specified by:

getDestination in interface Endpoint

setDestination

public void setDestination(java.lang.Object aDestination)

Specified by:

setDestination in interface Endpoint

setRegisteredWithParent

public void setRegisteredWithParent()

Specified by:

setRegisteredWithParent in interface Endpoint

isRegisteredWithParent

public boolean isRegisteredWithParent()

Specified by:

isRegisteredWithParent in interface Endpoint

setInitialFsHeapSize

public void setInitialFsHeapSize(int aHeapSize)

Specified by:

setInitialFsHeapSize in interface Endpoint

setTempReplyDestination

public void setTempReplyDestination(boolean isTempReplyDestination)

Specified by:

setTempReplyDestination in interface Endpoint

isTempReplyDestination

public boolean isTempReplyDestination()

Specified by:

isTempReplyDestination in interface Endpoint

setReplyDestinationFailed

public void setReplyDestinationFailed()

Specified by:

setReplyDestinationFailed in interface Endpoint

replyDestinationFailed

public boolean replyDestinationFailed()

Specified by:

replyDestinationFailed in interface Endpoint

getIdleTime

public long getIdleTime()

Specified by:

getIdleTime in interface Endpoint

setIdleTime

public void setIdleTime(long idleTime)

Specified by:

setIdleTime in interface Endpoint

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

setEndpointServer

public void setEndpointServer(java.lang.String anEndpointServer)

Specified by:

setEndpointServer in interface Endpoint

getEndpointServer

public java.lang.String getEndpointServer()

Specified by:

getEndpointServer in interface Endpoint

setConcurrentRequestConsumers

public void setConcurrentRequestConsumers(int aConsumerCount)

Specified by:

setConcurrentRequestConsumers in interface Endpoint

getConcurrentRequestConsumers

public int getConcurrentRequestConsumers()

Specified by:

getConcurrentRequestConsumers in interface Endpoint

setConcurrentReplyConsumers

public void setConcurrentReplyConsumers(int aConsumerCount)

Specified by:

setConcurrentReplyConsumers in interface Endpoint

getConcurrentReplyConsumers

public int getConcurrentReplyConsumers()

Specified by:

getConcurrentReplyConsumers in interface Endpoint

setStatus

public void setStatus(int aStatus)

Specified by:

setStatus in interface Endpoint

getStatus

public int getStatus()

Specified by:

getStatus in interface Endpoint

setDelegateKey

public void setDelegateKey(java.lang.String aDelegateKey)

Specified by:

setDelegateKey in interface Endpoint

getDelegateKey

public java.lang.String getDelegateKey()

Specified by:

getDelegateKey in interface Endpoint