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 2013/08/28 18:06:54 UTC
svn commit: r1518268 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
Author: cwiklik
Date: Wed Aug 28 16:06:53 2013
New Revision: 1518268
URL: http://svn.apache.org/r1518268
Log:
UIMA-3231 Modify Session reaper to log once
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java?rev=1518268&r1=1518267&r2=1518268&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsOutputChannel.java Wed Aug 28 16:06:53 2013
@@ -1916,6 +1916,8 @@ public class JmsOutputChannel implements
private ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
+ private boolean doLog = true;
+
public ConnectionTimer(BrokerConnectionEntry aBrokerDestinations) {
brokerDestinations = aBrokerDestinations;
}
@@ -1950,9 +1952,10 @@ public class JmsOutputChannel implements
// Fire the runnable at fixed intervals equal to inactivityTimeout value
scheduler.scheduleWithFixedDelay(new Runnable(){
public void run() {
- System.out.println("SessionReaper Thread Woke Up After:"+inactivityTimeout*60*1000+" Millis");
+ // System.out.println("SessionReaper Thread Woke Up After:"+inactivityTimeout*60*1000+" Millis");
long inactivityThreshold = inactivityTimeout*60*1000; // normalize into millis
- if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
+ if ( doLog && UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
+ doLog = false;
UIMAFramework.getLogger(CLASS_NAME).logrb(
Level.INFO,
CLASS_NAME.getName(),