Interface AnalysisEngineController

    • Method Detail

      • setInputChannel

        void setInputChannel​(InputChannel anInputChannel)
                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • addInputChannel

        void addInputChannel​(InputChannel anInputChannel)
                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getServiceEndpointName

        java.lang.String getServiceEndpointName()
      • handleDelegateLifeCycleEvent

        void handleDelegateLifeCycleEvent​(java.lang.String anEndpoint,
                                          int aDelegateCount)
      • takeAction

        void takeAction​(java.lang.String anAction,
                        java.lang.String anEndpointName,
                        ErrorContext anErrorContext)
      • getInputChannel

        InputChannel getInputChannel​(java.lang.String aQueueName)
      • saveReplyTime

        void saveReplyTime​(long snapshot,
                           java.lang.String aKey)
      • getReplyTime

        long getReplyTime()
      • getStats

        java.util.Map getStats()
      • getChildUimaContext

        org.apache.uima.UimaContext getChildUimaContext​(java.lang.String aDelegateEndpointName)
                                                 throws java.lang.Exception
        Throws:
        java.lang.Exception
      • dropCAS

        void dropCAS​(java.lang.String aCasReferenceId,
                     boolean dropCacheEntry)
      • dropCAS

        void dropCAS​(org.apache.uima.cas.CAS aCAS)
      • isPrimitive

        boolean isPrimitive()
      • getName

        java.lang.String getName()
      • getComponentName

        java.lang.String getComponentName()
      • isTopLevelComponent

        boolean isTopLevelComponent()
      • process

        void process​(org.apache.uima.cas.CAS aCas,
                     java.lang.String aCasId)
      • process

        void process​(org.apache.uima.cas.CAS aCAS,
                     java.lang.String anInputCasReferenceId,
                     java.lang.String aNewCasReferenceId,
                     java.lang.String newCASProducedBy)
      • process

        void process​(org.apache.uima.cas.CAS aCAS,
                     java.lang.String aCasReferenceId,
                     Endpoint anEndpoint)
      • saveTime

        void saveTime​(long anArrivalTime,
                      java.lang.String aCasReferenceId,
                      java.lang.String anEndpointName)
      • getTime

        long getTime​(java.lang.String aCasReferenceId,
                     java.lang.String anEndpointName)
      • setOutputChannel

        void setOutputChannel​(OutputChannel anOutputChannel)
                       throws java.lang.Exception
        Throws:
        java.lang.Exception
      • stop

        void stop()
      • isStopped

        boolean isStopped()
        Returns true if the AnalysisEngineController has been (or is in the process of) shutdown.
        Returns:
        - true if stopped
      • setStopped

        void setStopped()
        Called to set the state of the AnalysisEngineController to STOPPED. This method does not stop input or output channels.
      • dropStats

        void dropStats​(java.lang.String aCasReferenceId,
                       java.lang.String anEndpointName)
      • setUimaEEAdminContext

        void setUimaEEAdminContext​(UimaEEAdminContext anAdminContext)
      • getJMXDomain

        java.lang.String getJMXDomain()
      • getIndex

        int getIndex()
      • getJmxContext

        java.lang.String getJmxContext()
      • addServiceInfo

        void addServiceInfo​(ServiceInfo aServiceInfo)
      • setDeployDescriptor

        void setDeployDescriptor​(java.lang.String aDeployDescriptor)
      • cacheClientEndpoint

        void cacheClientEndpoint​(Endpoint anEndpoint)
      • getClientEndpoint

        Endpoint getClientEndpoint()
      • notifyListenersWithInitializationStatus

        void notifyListenersWithInitializationStatus​(java.lang.Exception e)
      • getCasStatistics

        ServicePerformance getCasStatistics​(java.lang.String aCasReferenceId)
      • isCasMultiplier

        boolean isCasMultiplier()
      • releaseNextCas

        void releaseNextCas​(java.lang.String aCasReferenceId)
      • getIdleTime

        long getIdleTime()
      • beginProcess

        void beginProcess​(int msgType)
      • endProcess

        void endProcess​(int msgType)
      • getIdleTimeBetweenProcessCalls

        long getIdleTimeBetweenProcessCalls​(int msgType)
      • getCpuTime

        long getCpuTime()
      • getAnalysisTime

        long getAnalysisTime()
      • incrementSerializationTime

        void incrementSerializationTime​(long cpuTime)
      • incrementDeserializationTime

        void incrementDeserializationTime​(long cpuTime)
      • onInitialize

        void onInitialize()
      • getUimaMessageListener

        UimaMessageListener getUimaMessageListener​(java.lang.String aDelegateKey)
      • getTransport

        UimaTransport getTransport​(UimaAsContext aContext,
                                   java.lang.String aKey)
                            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getTransport

        UimaTransport getTransport​(java.lang.String aKey)
                            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • initializeVMTransport

        void initializeVMTransport​(int parentControllerReplyConsumerCount)
                            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getReplyInputChannel

        InputChannel getReplyInputChannel​(java.lang.String aDelegateKey)
      • registerVmQueueWithJMX

        void registerVmQueueWithJMX​(java.lang.Object o,
                                    java.lang.String aName)
                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • addAbortedCasReferenceId

        void addAbortedCasReferenceId​(java.lang.String aCasReferenceId)
      • isAwaitingCacheCallbackNotification

        boolean isAwaitingCacheCallbackNotification()
      • quiesceAndStop

        void quiesceAndStop()
      • forceTimeoutOnPendingCases

        void forceTimeoutOnPendingCases​(java.lang.String key)
      • getDeadClientMap

        java.util.Map<java.lang.String,​java.lang.String> getDeadClientMap()
      • getKey

        java.lang.String getKey()
      • dumpState

        void dumpState​(java.lang.StringBuffer buffer,
                       java.lang.String lbl1)