You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/01/25 12:41:48 UTC
svn commit: r499746 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Author: rajdavies
Date: Thu Jan 25 03:41:42 2007
New Revision: 499746
URL: http://svn.apache.org/viewvc?view=rev&rev=499746
Log:
log when transport reconnects successfully
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?view=diff&rev=499746&r1=499745&r2=499746
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java Thu Jan 25 03:41:42 2007
@@ -187,7 +187,7 @@
if (transportListener != null){
transportListener.transportResumed();
}
-
+ log.info("Successfully reconnected to " + uri);
return false;
}
catch (Exception e) {
@@ -236,7 +236,7 @@
transportListener.transportInterupted();
}
synchronized (reconnectMutex) {
- log.info("Transport failed, attempting to automatically reconnect due to: " + e, e);
+ log.warn("Transport failed, attempting to automatically reconnect due to: " + e, e);
if (connectedTransport != null) {
initialized = false;
ServiceSupport.dispose(connectedTransport);