Author: cwiklik Date: Fri Jul 18 13:23:44 2014 New Revision: 1611643 URL: http://svn.apache.org/r1611643 Log: UIMA-3950 prevent thread from exiting on connectivity problems. Fixes a problem causing multiple calls on defineCasPool
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java?rev=1611643&r1=1611642&r2=1611643&view=diff ============================================================================== --- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java (original) +++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java Fri Jul 18 13:23:44 2014 @@ -153,10 +153,6 @@ public class UimaDefaultMessageListenerC // on observing jconsole attached to uima-as service with multiple listeners // on an endpoint. synchronized(UimaDefaultMessageListenerContainer.class ) { - ActiveMQConnection con = (ActiveMQConnection)super.getSharedConnection(); - if ( con != null && con.isStarted() && !con.isTransportFailed() ) { - return; - } while (isRunning() && !terminating ) { Connection tcon = null; try {