svn commit: r1066451 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java

[supun]

Author: supun
Date: Wed Feb  2 12:50:21 2011
New Revision: 1066451

URL: http://svn.apache.org/viewvc?rev=1066451&view=rev
Log:
removing the default support for not retrying for connection time out and 
connection close

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java?rev=1066451&r1=1066450&r2=1066451&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java
 Wed Feb  2 12:50:21 2011
@@ -335,29 +335,13 @@ public abstract class AbstractEndpoint e
     protected boolean isRetryDisabled(MessageContext synCtx) {
         Integer errorCode = (Integer) 
synCtx.getProperty(SynapseConstants.ERROR_CODE);
         if (errorCode != null) {
-            if (definition.getRetryDisabledErrorCodes().isEmpty()) {
-                // if timeout codes are not defined, assume only HTTP timeout 
and connection close
-                boolean isTimeout = SynapseConstants.NHTTP_CONNECTION_TIMEOUT 
== errorCode;
-                boolean isClosed = SynapseConstants.NHTTP_CONNECTION_CLOSED == 
errorCode;
-
-                if (isTimeout || isClosed) {
-
-                    if (log.isDebugEnabled()) {
-                        log.debug("Encountered a HTTP connection " + (isClosed 
? "close" :
-                                "timeout") + " error : " + errorCode + ", for 
which retries are " +
-                                "disabled by default");
-                    }
-                    return true;
-                }
-            } else {
-                if 
(definition.getRetryDisabledErrorCodes().contains(errorCode)) {
-                    if (log.isDebugEnabled()) {
-                        log.debug("Encountered a retry disabled error : " + 
errorCode
-                                + ", defined retry disabled error codes are : "
-                                + definition.getRetryDisabledErrorCodes());
-                    }
-                    return true;
+            if (definition.getRetryDisabledErrorCodes().contains(errorCode)) {
+                if (log.isDebugEnabled()) {
+                    log.debug("Encountered a retry disabled error : " + 
errorCode
+                            + ", defined retry disabled error codes are : "
+                            + definition.getRetryDisabledErrorCodes());
                 }
+                return true;
             }
         }