svn commit: r1210451 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/message: processors/ processors/forward/ store/

[hiranya]

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());