Package org.apache.uima.aae

Examples of org.apache.uima.aae.InputChannel

1575
1576
1577
1578
1579
1580
1581
1582
1583
1584
1585
1586
1587
1588
1589
1590
1591
1592
1593
1594
1595
1596
1597
1598
1599
1600
1601
1602
1603
1604
1605
1606
1607
1608
1609
1610
1611
1612
1613
1614
1615
1616
   * is configured with.
   *
   */
  protected void stopInputChannels()
  {
    InputChannel iC = null;
    try
    {
      if ( inputChannel != null )
      {
        inputChannel.stop();
      }
    }
    catch( Exception e) { e.printStackTrace();}
   
    Iterator it = inputChannelMap.keySet().iterator();
    int i=1;
    while( it.hasNext() )
    {
      try
      {   
        String key = (String)it.next();
        if ( key != null && key.trim().length() > 0)
        {
          iC = (InputChannel)inputChannelMap.get(key);
          if ( iC != null )
          {
            iC.stop();
          }
        }
        i++;
      }
      catch( Exception e)
      {
        if ( iC != null )
        {
          UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, getClass().getName(), "stopInputChannels", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE, "UIMAEE_unable_to_stop_inputchannel__INFO", new Object[] { getComponentName(), iC.getInputQueueName() });
        }
        else
        {
          UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, getClass().getName(), "stopInputChannels", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE, "UIMAEE_exception__WARNING", new Object[] { e });
        }
View Full Code Here
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
    }
    try {
      if (controller instanceof AggregateAnalysisEngineController) {
        String delegateKey = ((AggregateAnalysisEngineController) controller)
                .lookUpDelegateKey(endpoint.getEndpoint());
        InputChannel iC = null;
        String queueName = null;
        if (endpoint.getDestination() != null) {
          queueName = endpoint.getDestination().toString();
        } else {
          queueName = endpoint.getEndpoint();
        }
        iC = ((AggregateAnalysisEngineController) controller).getInputChannel(queueName);
        if (iC != null) {
          iC.destroyListener(queueName, delegateKey);
        } else {
          if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
               UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(),
                        "handleTempQueueFailure", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
                        "UIMAJMS_unable_to_lookup_input_channel__INFO", queueName);
View Full Code Here
2142
2143
2144
2145
2146
2147
2148
2149
2150
2151
2152
2153
2154
2155
2156
2157
2158
2159
    if (!isTopLevelComponent()) {
      ((BaseAnalysisEngineController) parentController).stop();
    } else if (!isStopped()) {
      stopDelegateTimers();
      getOutputChannel().cancelTimers();
      InputChannel iC = getInputChannel(endpointName);
      if ( iC != null) {
          iC.setTerminating();
      }
      // Stop the inflow of new input CASes
      stopInputChannel(true);  // shutdownNow
       if ( iC != null ) {
        iC.terminate();
      }
      stopCasMultipliers();
      stopTransportLayer();
      if (cause != null && aCasReferenceId != null) {
        this.stop(cause, aCasReferenceId, true);  // shutdownNow
View Full Code Here
2277
2278
2279
2280
2281
2282
2283
2284
2285
2286
2287
2288
2289
2290
  /**
   * Stops a listener on the main input channel
   *
   */
  protected void stopInputChannel(boolean shutdownNow) {
    InputChannel iC = getInputChannel(endpointName);
    if (iC != null && !iC.isStopped()) {
      try {
        iC.stop(shutdownNow);
      } catch (Exception e) {
        if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
          UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, getClass().getName(), "terminate",
                  UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
                  "UIMAEE_unable_to_stop_inputchannel__INFO",
View Full Code Here
2293
2294
2295
2296
2297
2298
2299
2300
2301
      }
    }
  }
  private void setInputChannelForNoRecovery() {
    if ( inputChannelMap.size() > 0 ) {
      InputChannel iC = getInputChannel();
      iC.setTerminating();
    }
  }
View Full Code Here
2299
2300
2301
2302
2303
2304
2305
2306
2307
2308
2309
2310
2311
2312
2313
2314
2315
2316
2317
2318
2319
2320
2321
2322
2323
2324
2325
2326
2327
2328
2329
2330
2331
      iC.setTerminating();
    }
  }
  protected void stopReceivingCASes(boolean stopAllListeners)  {
   
      InputChannel iC = null;
      setInputChannelForNoRecovery();
      Iterator<String> it = inputChannelMap.keySet().iterator();
      while (it.hasNext()) {
        try {
          String key = it.next();
          if (key != null && key.trim().length() > 0) {
            iC = (InputChannel) inputChannelMap.get(key);
            if (iC != null ) {
              if ( stopAllListeners ) {
                iC.disconnectListenersFromQueue();
              } else if ( iC.getInputQueueName() != null && !iC.getInputQueueName().startsWith("temp-queue")) {
                iC.disconnectListenersFromQueue();
              }
            }
          }
        } catch (Exception e) {
          if (iC != null) {
            if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
              UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, getClass().getName(),
                      "stopReceivingCASes", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
                      "UIMAEE_unable_to_stop_inputchannel__INFO",
                      new Object[] { getComponentName(), iC.getInputQueueName() });
            }
          } else {
            if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.WARNING)) {
              UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, CLASS_NAME.getName(),
                      "stopReceivingCASes", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
View Full Code Here
2338
2339
2340
2341
2342
2343
2344
2345
2346
2347
2348
2349
2350
2351
2352
2353
2354
2355
2356
2357
2358
2359
2360
2361
2362
2363
2364
2365
2366
2367
2368
2369
2370
2371
2372
2373
2374
2375
        }
      }
   
  }
  protected void stopInputChannels( int channelsToStop, boolean shutdownNow) {   //, boolean norecovery) {
      InputChannel iC = null;
      setInputChannelForNoRecovery();
      Iterator it = inputChannelMap.keySet().iterator();
      int i = 1;
      while (it.hasNext()) {
        try {
          String key = (String) it.next();
          if (key != null && key.trim().length() > 0) {
            iC = (InputChannel) inputChannelMap.get(key);
            if (iC != null) {
              if (channelsToStop == InputChannel.InputChannels && iC.getServiceInfo() != null
                      && iC.getServiceInfo().getInputQueueName().startsWith("top_level_input_queue")) {
                // This closes both listeners on the input queue: Process Listener and GetMeta
                // Listener
                iC.stop(channelsToStop,shutdownNow);
                return; // Just closed input channels. Keep the others open
              }
              iC.stop(channelsToStop,shutdownNow);
            }
          }
          i++;
        } catch (Exception e) {
          if (iC != null) {
            if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
              UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, getClass().getName(),
                      "stopInputChannels", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
                      "UIMAEE_unable_to_stop_inputchannel__INFO",
                      new Object[] { getComponentName(), iC.getInputQueueName() });
            }
          } else {
            if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.WARNING)) {
              UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, CLASS_NAME.getName(),
                      "stopInputChannels", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
View Full Code Here
2406
2407
2408
2409
2410
2411
2412
2413
2414
2415
2416
2417
  }

  public InputChannel getInputChannel(String anEndpointName) {

    for (int i = 0; inputChannelList != null && i < inputChannelList.size(); i++) {
      InputChannel iC = (InputChannel) inputChannelList.get(i);
      if (iC.isListenerForDestination(anEndpointName)) {
        return (InputChannel) inputChannelList.get(i);
      }
    }
    return null;
  }
View Full Code Here
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
                //  Only one thread at a time is allowed here.
                synchronized( masterEndpoint ) {
                  if ( masterEndpoint.getStatus() == Endpoint.FAILED ) {
                    //  Returns InputChannel if the Reply Listener for the delegate has previously failed.
                    //  If the listener hasnt failed the getReplyInputChannel returns null
                    InputChannel iC = getAnalysisEngineController().getReplyInputChannel(anEndpoint.getDelegateKey());
                    if ( iC != null ) {
                      try {
                        // Create a new Listener, new Temp Queue and associate the listener with the Input Channel
                      // Also resets endpoint status to OK 
                        iC.createListener(anEndpoint.getDelegateKey(), anEndpoint);
                        iC.removeDelegateFromFailedList(masterEndpoint.getDelegateKey());
                      } catch( Exception exx) {
                        throw new AsynchAEException(exx);
                      }
                    } else{
                      throw new AsynchAEException("Aggregate:"+getAnalysisEngineController()+" Has not yet recovered a listener for delegate: "+anEndpoint.getDelegateKey());
View Full Code Here
2083
2084
2085
2086
2087
2088
2089
2090
2091
2092
2093
2094
2095
2096
      outputChannel.removeCasFromOutstandingList(entry, isRequest, endpoint.getDelegateKey());
      if (delegate != null) {
        // Mark this delegate as Failed
        delegate.getEndpoint().setStatus(Endpoint.FAILED);
        // Destroy listener associated with a reply queue for this delegate
        InputChannel ic = controller.getInputChannel(delegate.getEndpoint().getDestination()
                .toString());
        if (ic != null && delegate != null && delegate.getEndpoint() != null) {
          ic.destroyListener(delegate.getEndpoint().getDestination().toString(), endpoint
                  .getDelegateKey());
        }
        // Setup error context and handle failure in the error handler
        ErrorContext errorContext = new ErrorContext();
        errorContext.add(AsynchAEMessage.Command, AsynchAEMessage.Process);
View Full Code Here
TOP

Related Classes of org.apache.uima.aae.InputChannel

  • org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl
  • org.apache.uima.aae.controller.BaseAnalysisEngineController
  • org.apache.uima.aae.error.ErrorHandlerBase
  • org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl
  • org.apache.uima.adapter.jms.activemq.JmsOutputChannel
  • org.apache.uima.adapter.jms.activemq.JmsOutputChannel$RecoveryThread
  • org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.