Author: charith
Date: Tue Dec 6 08:23:19 2011
New Revision: 1210821
URL: http://svn.apache.org/viewvc?rev=1210821&view=rev
Log:
fix SYNAPSE-820
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointContext.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointContext.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointContext.java?rev=1210821&r1=1210820&r2=1210821&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointContext.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointContext.java
Tue Dec 6 08:23:19 2011
@@ -387,7 +387,7 @@ public class EndpointContext {
} else if (state == ST_OFF) {
return false;
- } else if (System.currentTimeMillis() > nextRetryTime) {
+ } else if (System.currentTimeMillis() >= nextRetryTime) {
// if we are not active, but reached the next retry time,
return true but do not
// make a state change. We will make the state change on a
successful send
// if we are in the ST_TIMEOUT state, reduce a remaining
retry
@@ -420,13 +420,12 @@ public class EndpointContext {
} else if (localState == ST_OFF) {
return false;
- } else if (System.currentTimeMillis() > localNextRetryTime) {
+ } else if (System.currentTimeMillis() >= localNextRetryTime) {
// if we are not active, but reached the next retry time,
return true but do not
// make a state change. We will make the state change on a
successful send
// if we are in the ST_TIMEOUT state, reduce a remaining retry
if (localState == ST_TIMEOUT) {
- localRemainingRetries--;
if (log.isDebugEnabled()) {
log.debug("Endpoint : " + endpointName + " which is
currently in timeout " +
