synapse-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sami...@apache.org
Subject svn commit: r425283 - /incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/EmptyRMMessageReceiver.java
Date Tue, 25 Jul 2006 05:16:12 GMT
Author: saminda
Date: Mon Jul 24 22:16:11 2006
New Revision: 425283

URL: http://svn.apache.org/viewvc?rev=425283&view=rev
Log:
added injection method to EmptyRMMessageReceiver

Modified:
    incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/EmptyRMMessageReceiver.java

Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/EmptyRMMessageReceiver.java
URL: http://svn.apache.org/viewvc/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/EmptyRMMessageReceiver.java?rev=425283&r1=425282&r2=425283&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/EmptyRMMessageReceiver.java
(original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/EmptyRMMessageReceiver.java
Mon Jul 24 22:16:11 2006
@@ -18,19 +18,30 @@
 import org.apache.axis2.engine.MessageReceiver;
 import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.AxisFault;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 /*
  * 
  */
 
 public class EmptyRMMessageReceiver implements MessageReceiver {
+
+    private static Log log = LogFactory.getLog(EmptyRMMessageReceiver.class);
+
     public void receive(MessageContext messageContext) throws AxisFault {
         /*
          Message Recieved with RM
         */
-        //TODO : SynapseEnvironment Inject
-        System.out.println("########  EmptyRMMessageReceiver ######");
-        System.out.println("########   Envelope  :  " + messageContext.getEnvelope().toString());
         
+        log.info("EmptyRMMessageReceiver#receive() and inject the Message into Synapse Environment");
+        log.debug("Application Message  :  " + messageContext.getEnvelope().toString());
+
+        org.apache.synapse.MessageContext synCtx =
+                Axis2MessageContextFinder.getSynapseMessageContext(messageContext);
+        synCtx.getEnvironment().injectMessage(synCtx);
+
+        log.debug("Executed EmptyRMMessageReceiver#receive() and Java Return for RMMediator");
+
 
         messageContext.setProperty(
                 org.apache.synapse.Constants.MESSAGE_RECEIVED_RM_ENGAGED,



---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org


Mime
View raw message