You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@synapse.apache.org by hi...@apache.org on 2011/12/19 09:00:43 UTC

svn commit: r1220639 - /synapse/branches/2.1/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java

Author: hiranya
Date: Mon Dec 19 08:00:43 2011
New Revision: 1220639

URL: http://svn.apache.org/viewvc?rev=1220639&view=rev
Log:
Fixing SYNAPSE-829

Modified:
    synapse/branches/2.1/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java

Modified: synapse/branches/2.1/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java
URL: http://svn.apache.org/viewvc/synapse/branches/2.1/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java?rev=1220639&r1=1220638&r2=1220639&view=diff
==============================================================================
--- synapse/branches/2.1/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java (original)
+++ synapse/branches/2.1/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java Mon Dec 19 08:00:43 2011
@@ -122,6 +122,11 @@ public class ForwardingJob implements St
                 if (targetEp != null) {
                     Endpoint ep = messageContext.getEndpoint(targetEp);
 
+                    // stop processing if endpoint is not ready to send
+                    if(!ep.getContext().readyToSend()) {
+                        return;
+                    }
+
                     if (ep instanceof AddressEndpoint) {
 
                         try {