Interface AggregateAnalysisEngineController

    • Method Detail

      • mergeTypeSystem

        void mergeTypeSystem​(java.lang.String aTypeSystem,
                             java.lang.String fromDestination,
                             java.lang.String fromServer)
                      throws AsynchAEException
        Throws:
        AsynchAEException
      • addMessageOrigin

        void addMessageOrigin​(java.lang.String aCasReferenceId,
                              Endpoint anEndpoint)
      • getMessageOrigin

        Endpoint getMessageOrigin​(java.lang.String aCasReferenceId)
      • removeMessageOrigin

        void removeMessageOrigin​(java.lang.String aCasReferenceId)
      • processCollectionCompleteReplyFromDelegate

        void processCollectionCompleteReplyFromDelegate​(java.lang.String aDelegateKey,
                                                        boolean sendReply)
                                                 throws AsynchAEException
        Throws:
        AsynchAEException
      • isDelegateKeyValid

        boolean isDelegateKeyValid​(java.lang.String anEndpointName)
      • mapEndpointsToKeys

        void mapEndpointsToKeys​(java.util.concurrent.ConcurrentHashMap aDestinationMap)
      • retryLastCommand

        void retryLastCommand​(int aCommand,
                              Endpoint anEndpoint,
                              java.lang.String aCasReferenceId)
      • lookUpDelegateKey

        java.lang.String lookUpDelegateKey​(java.lang.String aDelegateEndpointName)
      • lookUpDelegateKey

        java.lang.String lookUpDelegateKey​(java.lang.String aDelegateEndpointName,
                                           java.lang.String server)
      • getChildUimaContext

        org.apache.uima.UimaContext getChildUimaContext​(java.lang.String aDelegateEndpointName)
                                                 throws java.lang.Exception
        Specified by:
        getChildUimaContext in interface AnalysisEngineController
        Throws:
        java.lang.Exception
      • continueOnError

        boolean continueOnError​(java.lang.String aCasReferenceId,
                                java.lang.String aDelegateKey,
                                java.lang.Exception anException)
                         throws AsynchAEException
        Throws:
        AsynchAEException
      • dropFlow

        void dropFlow​(java.lang.String aCasReferenceId,
                      boolean dropFlow)
      • isDelegateDisabled

        boolean isDelegateDisabled​(java.lang.String aDelegateKey)
      • getLastDelegateKeyFromFlow

        java.lang.String getLastDelegateKeyFromFlow​(java.lang.String anInputCasReferenceId)
      • registerChildController

        void registerChildController​(AnalysisEngineController aChildController,
                                     java.lang.String aDelegateKey)
                              throws java.lang.Exception
        Throws:
        java.lang.Exception
      • saveStatsFromService

        void saveStatsFromService​(java.lang.String aServiceEndpointName,
                                  java.util.Map aServiceStats)
      • getDelegateStats

        java.util.Map getDelegateStats()
      • getDelegateServicePerformance

        ServicePerformance getDelegateServicePerformance​(java.lang.String aDelegateKey)
      • getDelegateServiceInfo

        PrimitiveServiceInfo getDelegateServiceInfo​(java.lang.String aDelegateKey)
      • getDelegateServiceErrors

        ServiceErrors getDelegateServiceErrors​(java.lang.String aDelegateKey)
      • stopTimers

        void stopTimers()
      • requestForMetaSentToRemotes

        boolean requestForMetaSentToRemotes()
      • setRequestForMetaSentToRemotes

        void setRequestForMetaSentToRemotes()
      • getDestinations

        java.util.Map getDestinations()
      • getServicePerformance

        ServicePerformance getServicePerformance​(java.lang.String aDelegateKey)
      • finalStep

        void finalStep​(org.apache.uima.flow.FinalStep aStep,
                       java.lang.String aCasReferenceId)
      • lookupDelegate

        Delegate lookupDelegate​(java.lang.String aDelegateKey)
      • delayCasIfDelegateInTimedOutState

        boolean delayCasIfDelegateInTimedOutState​(java.lang.String aCasReferenceId,
                                                  java.lang.String aDelegateKey)
                                           throws AsynchAEException
        Throws:
        AsynchAEException
      • getChildControllerList

        java.util.List getChildControllerList()
      • stopCasMultiplier

        void stopCasMultiplier​(Delegate casMultiplier,
                               java.lang.String aCasReferenceId)
      • setCasLoggingDirectory

        void setCasLoggingDirectory​(java.lang.String key,
                                    java.lang.String directoryName)
      • changeCollocatedDelegateState

        void changeCollocatedDelegateState​(java.lang.String delegateKey,
                                           BaseAnalysisEngineController.ServiceState state)
                                    throws java.lang.Exception
        Throws:
        java.lang.Exception