You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by as...@apache.org on 2008/01/02 08:36:53 UTC
svn commit: r608031 -
/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSConnectionFactory.java
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: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org