Author: charith
Date: Fri May 20 15:30:53 2011
New Revision: 1125431
URL: http://svn.apache.org/viewvc?rev=1125431&view=rev
Log:
Fxing issue in Message processors
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/BlockingMessageSender.java
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/ScheduledMessageProcessor.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java?rev=1125431&r1=1125430&r2=1125431&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/ScheduledMessageProcessor.java
Fri May 20 15:30:53 2011
@@ -35,7 +35,6 @@ public abstract class ScheduledMessagePr
public static final String SCHEDULED_MESSAGE_PROCESSOR_GROUP =
"synapse.message.processor.quartz";
- protected Log log = LogFactory.getLog(this.getClass());
/**
* The scheduler, run the the processor
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/BlockingMessageSender.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/BlockingMessageSender.java?rev=1125431&r1=1125430&r2=1125431&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/BlockingMessageSender.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/BlockingMessageSender.java
Fri May 20 15:30:53 2011
@@ -130,7 +130,12 @@ public class BlockingMessageSender {
OMElement result = null;
try {
OMElement payload =
axis2Ctx.getEnvelope().getBody().getFirstElement();
- result = sc.sendReceive(payload);
+ if(outOnlyMessage) {
+ sc.sendRobust(payload);
+ } else {
+ result = sc.sendReceive(payload);
+ }
+
} catch (Exception axisFault) {
// Here if Message is not a Out only Message
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=1125431&r1=1125430&r2=1125431&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
Fri May 20 15:30:53 2011
@@ -158,6 +158,9 @@ public class ForwardingJob implements St
errorStop = true;
continue;
+ } else if(outCtx == null) {
+ // This Means we have invoked an out only
operation
+ messageStore.poll();
}
// If there is a sequence defined to send success
replies,
