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 2009/07/24 15:30:46 UTC

svn commit: r797440 - /incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java

Author: cwiklik
Date: Fri Jul 24 13:30:46 2009
New Revision: 797440

URL: http://svn.apache.org/viewvc?rev=797440&view=rev
Log:
UIMA-1439 Added new method cancelTimers to cancel all timer threads that time connection to a broker managing reply queues

Modified:
    incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java

Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java?rev=797440&r1=797439&r2=797440&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java Fri Jul 24 13:30:46 2009
@@ -25,6 +25,7 @@
 import java.util.Date;
 import java.util.Iterator;
 import java.util.Map;
+import java.util.Set;
 import java.util.StringTokenizer;
 import java.util.Timer;
 import java.util.TimerTask;
@@ -2058,6 +2059,18 @@
 		}
 		return null;
 	}
+  public void cancelTimers() {
+    if ( connectionMap.size() > 0 ) {
+      Iterator<String> it = connectionMap.keySet().iterator();
+      while (it.hasNext() ) {
+        String key = it.next();
+        BrokerConnectionEntry ce = (BrokerConnectionEntry) connectionMap.get(key);
+        if ( ce.getConnectionTimer() != null ) {
+          ce.getConnectionTimer().cancelTimer();
+        }
+      }
+    }
+  }
 
 	public class BrokerConnectionEntry {
 	  private String brokerURL;
@@ -2133,9 +2146,9 @@
       }
       if (controller != null) {
         timer = new Timer("Controller:" + controller.getComponentName()
-                + ":TimerThread-:" + endpoint + ":" + System.nanoTime());
+                + ":Reply TimerThread-:" + endpoint + ":" + System.nanoTime());
       } else {
-        timer = new Timer("TimerThread-:" + endpoint + ":"
+        timer = new Timer("Reply TimerThread-:" + endpoint + ":"
                 + System.nanoTime());
       }
       timer.schedule(new TimerTask() {