Author: hiranya
Date: Mon Dec 19 08:00:22 2011
New Revision: 1220638
URL: http://svn.apache.org/viewvc?rev=1220638&view=rev
Log:
Fixing SYNAPSE-829
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java?rev=1220638&r1=1220637&r2=1220638&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ForwardingJob.java
Mon Dec 19 08:00:22 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 {
