Package org.apache.uima.aae

Examples of org.apache.uima.aae.InputChannel.stop()

1597
1598
1599
1600
1601
1602
1603
1604
1605
1606
1607
        if ( key != null && key.trim().length() > 0)
        {
          iC = (InputChannel)inputChannelMap.get(key);
          if ( iC != null )
          {
            iC.stop();
          }
        }
        i++;
      }
      catch( Exception e)
View Full Code Here
2280
2281
2282
2283
2284
2285
2286
2287
2288
2289
2290
   */
  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
2352
2353
2354
2355
2356
2357
2358
2359
2360
2361
2362
            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);
            }
          }
View Full Code Here
2355
2356
2357
2358
2359
2360
2361
2362
2363
2364
2365
                // 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) {
View Full Code Here
2267
2268
2269
2270
2271
2272
2273
2274
2275
2276
2277
   */
  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
2339
2340
2341
2342
2343
2344
2345
2346
2347
2348
2349
            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);
            }
          }
View Full Code Here
2342
2343
2344
2345
2346
2347
2348
2349
2350
2351
2352
                // 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) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.