activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r420873 - in /incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport: InactivityMonitor.java failover/FailoverTransport.java
Date Tue, 11 Jul 2006 14:33:22 GMT
Author: chirino
Date: Tue Jul 11 07:33:22 2006
New Revision: 420873

URL: http://svn.apache.org/viewvc?rev=420873&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-608

Modified:
    incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
    incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java?rev=420873&r1=420872&r2=420873&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
(original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
Tue Jul 11 07:33:22 2006
@@ -71,19 +71,19 @@
         
     private void writeCheck() {
         if( inSend.get() ) {
-            log.debug("A send is in progress");
+            log.trace("A send is in progress");
             return;
         }
         
         if( !commandSent.get() ) {
-            log.debug("No message sent since last write check, sending a KeepAliveInfo");
+            log.trace("No message sent since last write check, sending a KeepAliveInfo");
             try {
                 next.oneway(new KeepAliveInfo());                
             } catch (IOException e) {
                 onException(e);
             }
         } else {
-            log.debug("Message sent since last write check, resetting flag");
+            log.trace("Message sent since last write check, resetting flag");
         }
         
         commandSent.set(false);
@@ -92,15 +92,15 @@
 
     private void readCheck() {
         if( inReceive.get() ) {
-            log.debug("A receive is in progress");
+            log.trace("A receive is in progress");
             return;
         }
         
         if( !commandReceived.get() ) {
-            log.debug("No message received since last read check! ");
+            log.debug("No message received since last read check for " + toString() + "!
Throwing InactivityIOException.");
             onException(new InactivityIOException("Channel was inactive for too long."));
          
         } else {
-            log.debug("Message received since last read check, resetting flag: ");
+            log.trace("Message received since last read check, resetting flag: ");
         }
         
         commandReceived.set(false);

Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=420873&r1=420872&r2=420873&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
(original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Tue Jul 11 07:33:22 2006
@@ -194,8 +194,8 @@
                 }
 
                 if(!disposed){
-                        if( log.isTraceEnabled() )
-                            log.trace("Waiting "+reconnectDelay+" ms before attempting connection.
");
+                    
+                        log.debug("Waiting "+reconnectDelay+" ms before attempting connection.
");
                         synchronized(sleepMutex){
                             try{
                                 sleepMutex.wait(reconnectDelay);
@@ -339,7 +339,7 @@
 
                         // Wait for transport to be connected.
                         while (connectedTransport == null && !disposed &&
connectionFailure==null ) {
-                            log.debug("Waiting for transport to reconnect.");
+                            log.trace("Waiting for transport to reconnect.");
                             try {
                                 reconnectMutex.wait(1000);
                             }



Mime
View raw message