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/05 14:14:13 UTC
svn commit: r1210451 - in
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message:
processors/ processors/forward/ store/
Author: hiranya
Date: Mon Dec 5 13:14:12 2011
New Revision: 1210451
URL: http://svn.apache.org/viewvc?rev=1210451&view=rev
Log:
Fixing an issue with persisting messages in a message store
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/ScheduledMessageForwardingProcessor.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/store/InMemoryMessageStore.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=1210451&r1=1210450&r2=1210451&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 Mon Dec 5 13:14:12 2011
@@ -191,4 +191,5 @@ public abstract class ScheduledMessagePr
}
state = State.DESTROY;
}
+
}
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=1210451&r1=1210450&r2=1210451&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 Mon Dec 5 13:14:12 2011
@@ -132,7 +132,6 @@ public class BlockingMessageSender {
// otherwise when retrying same header element will add multiple times
sc.removeHeaders();
- axis2Ctx.getAttachmentMap();
Iterator itr = axis2Ctx.getEnvelope().getHeader().getChildren();
while (itr.hasNext()) {
Object o =itr.next();
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java?rev=1210451&r1=1210450&r2=1210451&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/processors/forward/ScheduledMessageForwardingProcessor.java Mon Dec 5 13:14:12 2011
@@ -148,4 +148,3 @@ public class ScheduledMessageForwardingP
return view;
}
}
-
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/store/InMemoryMessageStore.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/store/InMemoryMessageStore.java?rev=1210451&r1=1210450&r2=1210451&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/store/InMemoryMessageStore.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message/store/InMemoryMessageStore.java Mon Dec 5 13:14:12 2011
@@ -44,6 +44,7 @@ public class InMemoryMessageStore extend
lock.lock();
try {
if (messageContext != null) {
+ messageContext.getEnvelope().build();
messageList.put(messageContext.getMessageID(), messageContext);
/** Notify observers */
notifyMessageAddition(messageContext.getMessageID());