Author: asankha
Date: Tue Jan 1 23:36:45 2008
New Revision: 608031
URL: http://svn.apache.org/viewvc?rev=608031&view=rev
Log:
fix log messages on connection retry after failures
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSConnectionFactory.java
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSConnectionFactory.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSConnectionFactory.java?rev=608031&r1=608030&r2=608031&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSConnectionFactory.java
(original)
+++
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSConnectionFactory.java
Tue Jan 1 23:36:45 2008
@@ -602,29 +602,29 @@
}
public void onException(JMSException e) {
- log.error("jms error ", e);
- boolean wasError = true;
-
- // try to connect
- // if error occurs wait and try again
- while(wasError == true) {
-
- try {
- connectAndListen();
- wasError = false;
-
- } catch (Exception e1) {
- log.error("jms reconnect error ", e);
- }
-
- if(wasError == true) {
- try {
- Thread.sleep(getReconnectTimeout());
- } catch (InterruptedException e2) {
- e2.printStackTrace();
- }
- }
- } // wasError
-
+ log.error("JMS connection factory " + name + " encountered an error",
e);
+ boolean wasError = true;
+
+ // try to connect
+ // if error occurs wait and try again
+ while (wasError == true) {
+
+ try {
+ connectAndListen();
+ wasError = false;
+
+ } catch (Exception e1) {
+ log.warn("JMS reconnection attempt failed for connection
factory : " + name, e);
+ }
+
+ if (wasError == true) {
+ try {
+ log.info("Attempting reconnection for connection factory "
+ name +
+ " in " + getReconnectTimeout()/1000 + " seconds");
+ Thread.sleep(getReconnectTimeout());
+ } catch (InterruptedException ignore) {}
+ }
+ } // wasError
+
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
