Author: cwiklik
Date: Mon Feb 14 15:19:31 2011
New Revision: 1070517
URL: http://svn.apache.org/viewvc?rev=1070517&view=rev
Log:
UIMA-2038 Modified stop to always call listener destroy() method
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java?rev=1070517&r1=1070516&r2=1070517&view=diff
==============================================================================
---
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
(original)
+++
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
Mon Feb 14 15:19:31 2011
@@ -909,7 +909,7 @@ public class JmsInputChannel implements
List<UimaDefaultMessageListenerContainer> listenersToRemove = new
ArrayList<UimaDefaultMessageListenerContainer>();
for (Object listenerObject : listenerContainerList) {
final UimaDefaultMessageListenerContainer mL =
(UimaDefaultMessageListenerContainer) listenerObject;
- if (mL != null && mL.isRunning() && doCloseChannel(mL, channelsToClose))
{
+ if (mL != null && doCloseChannel(mL, channelsToClose)) {
stopChannel(mL);
// Just in case check if the container still in the list. If so, add
it to
// another list that container listeners that have been stopped and
need
