You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2014/07/18 15:23:45 UTC
svn commit: r1611643 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
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 {