org.apache.uima.aae.controller
Class Endpoint_impl

java.lang.Object
  extended by 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
Endpoint_impl()
           
 
Method Summary
 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


Copyright © 2011. All Rights Reserved.