You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by ru...@apache.org on 2008/01/28 12:16:00 UTC

svn commit: r615854 - /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java

Author: ruwan
Date: Mon Jan 28 03:15:52 2008
New Revision: 615854

URL: http://svn.apache.org/viewvc?rev=615854&view=rev
Log:
Fixing an issue with the aggregate

Modified:
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java?rev=615854&r1=615853&r2=615854&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java Mon Jan 28 03:15:52 2008
@@ -144,7 +144,7 @@
         }
 
         // else, has this aggregation reached its timeout?
-        if (System.currentTimeMillis() >= expiryTimeMillis) {
+        if (expiryTimeMillis > 0 && System.currentTimeMillis() >= expiryTimeMillis) {
             if (traceOrDebugOn) {
                 traceOrDebug(traceOn, trace, log,
                     "Aggregation complete - the aggregation has timed out");



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org