Package org.apache.uima.aae

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

2236
2237
2238
2239
2240
2241
2242
2243
2244
2245
2246
   */
  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
2304
2305
2306
2307
2308
2309
2310
2311
2312
2313
2314
            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
2307
2308
2309
2310
2311
2312
2313
2314
2315
2316
2317
                // 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
2150
2151
2152
2153
2154
2155
2156
2157
2158
2159
2160
   */
  protected void stopInputChannel() {
    InputChannel iC = getInputChannel(endpointName);
    if (iC != null && !iC.isStopped()) {
      try {
        iC.stop();
      } 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
2182
2183
2184
2185
2186
2187
2188
2189
2190
2191
2192
            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);
                return; // Just closed input channels. Keep the others open
              }
              iC.stop(channelsToStop);
            }
          }
View Full Code Here
2185
2186
2187
2188
2189
2190
2191
2192
2193
2194
2195
                // This closes both listeners on the input queue: Process Listener and GetMeta
                // Listener
                iC.stop(channelsToStop);
                return; // Just closed input channels. Keep the others open
              }
              iC.stop(channelsToStop);
            }
          }
          i++;
        } catch (Exception e) {
          if (iC != null) {
View Full Code Here
2081
2082
2083
2084
2085
2086
2087
2088
2089
2090
2091
   */
  protected void stopInputChannel() {
    InputChannel iC = getInputChannel(endpointName);
    if (iC != null && !iC.isStopped()) {
      try {
        iC.stop();
      } 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
2112
2113
2114
2115
2116
2117
2118
2119
2120
2121
2122
          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);
              return; // Just closed input channels. Keep the others open
            }
            iC.stop(channelsToStop);
          }
        }
View Full Code Here
2115
2116
2117
2118
2119
2120
2121
2122
2123
2124
2125
              // This closes both listeners on the input queue: Process Listener and GetMeta
              // Listener
              iC.stop(channelsToStop);
              return; // Just closed input channels. Keep the others open
            }
            iC.stop(channelsToStop);
          }
        }
        i++;
      } catch (Exception e) {
        if (iC != null) {
View Full Code Here
1560
1561
1562
1563
1564
1565
1566
1567
1568
1569
1570
    if( iC != null && !iC.isStopped())
    {
      try
      {
        System.out.println("Controller:"+getComponentName()+" Stopping Input Channel:"+iC.getInputQueueName());
        iC.stop();
      }
      catch( Exception e)
      {
        UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, getClass().getName(), "terminate", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE, "UIMAEE_unable_to_stop_inputchannel__INFO", new Object[] { getComponentName(), endpointName });
      }
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.