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() {