}
}
}
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,