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 {
