svn commit: r1747332 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/tasks/MessageInjector.java

[isudana]

Author: isudana
Date: Wed Jun  8 01:32:59 2016
New Revision: 1747332

URL: http://svn.apache.org/viewvc?rev=1747332&view=rev
Log:
applying patch by prabath to fix SYNAPSE-1042

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/tasks/MessageInjector.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/tasks/MessageInjector.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/tasks/MessageInjector.java?rev=1747332&r1=1747331&r2=1747332&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/tasks/MessageInjector.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/tasks/MessageInjector.java
 Wed Jun  8 01:32:59 2016
@@ -39,6 +39,7 @@ import org.apache.synapse.mediators.Medi
 import org.apache.synapse.mediators.base.SequenceMediator;
 import org.apache.synapse.task.Task;
 import org.apache.synapse.util.PayloadHelper;
+import org.apache.axiom.util.UIDGenerator;
 
 /**
  * Injects a Message into a named sequence or a proxy service configured in 
the Synapse
@@ -209,6 +210,7 @@ public class MessageInjector implements
             axis2MsgCtx.setConfigurationContext(configurationContext);
             axis2MsgCtx.setIncomingTransportName(Constants.TRANSPORT_LOCAL);
             axis2MsgCtx.setServerSide(true);
+            axis2MsgCtx.setMessageID(UIDGenerator.generateURNString());
 
             try {
                 AxisService axisService = 
configurationContext.getAxisConfiguration().
@@ -266,6 +268,7 @@ public class MessageInjector implements
 
         } else {
             MessageContext mc = synapseEnvironment.createMessageContext();
+            mc.setMessageID(UIDGenerator.generateURNString());
             mc.pushFaultHandler(new 
MediatorFaultHandler(mc.getFaultSequence()));
             if (to != null) {
                 mc.setTo(new EndpointReference(to));