svn commit: r473678 - in /incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core: SynapseEnvironment.java axis2/Axis2SynapseEnvironment.java axis2/SynapseModule.java

[antelder]

Author: antelder
Date: Sat Nov 11 01:56:10 2006
New Revision: 473678

URL: http://svn.apache.org/viewvc?view=rev&rev=473678
Log:
Add method to create a MessageContext to the SynapseEnvironment

Modified:
    
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/SynapseEnvironment.java
    
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
    
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/SynapseModule.java

Modified: 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/SynapseEnvironment.java
URL: 
http://svn.apache.org/viewvc/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/SynapseEnvironment.java?view=diff&rev=473678&r1=473677&r2=473678
==============================================================================
--- 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/SynapseEnvironment.java
 (original)
+++ 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/SynapseEnvironment.java
 Sat Nov 11 01:56:10 2006
@@ -36,4 +36,10 @@
      * This will send request messages on (forward), and send the response 
messages back to the client
      */
     public void send(MessageContext smc);
+    
+    /**
+     * Creates a new Synapse <code>MessageContext</code> instance.
+     * @return a MessageContext
+     */
+    public MessageContext createMessageContext();
 }

Modified: 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
URL: 
http://svn.apache.org/viewvc/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java?view=diff&rev=473678&r1=473677&r2=473678
==============================================================================
--- 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
 (original)
+++ 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
 Sat Nov 11 01:56:10 2006
@@ -16,12 +16,12 @@
 
 package org.apache.synapse.core.axis2;
 
-import org.apache.axis2.engine.AxisConfiguration;
 import org.apache.axis2.context.ConfigurationContext;
 import org.apache.axis2.util.threadpool.ThreadFactory;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.synapse.MessageContext;
+import org.apache.synapse.config.SynapseConfiguration;
 import org.apache.synapse.core.SynapseEnvironment;
 
 /**
@@ -34,10 +34,13 @@
     private ConfigurationContext cfgCtx = null;
     private ThreadFactory threadFactory = null;
 
+    private SynapseConfiguration synapseConfig;
+
     public Axis2SynapseEnvironment() {}
 
-    public Axis2SynapseEnvironment(ConfigurationContext cfgCtx) {
+    public Axis2SynapseEnvironment(ConfigurationContext cfgCtx, 
SynapseConfiguration synapseConfig) {
         this.cfgCtx = cfgCtx;
+        this.synapseConfig = synapseConfig;
         threadFactory = cfgCtx.getThreadPool();
     }
 
@@ -56,6 +59,12 @@
             Axis2Sender.sendBack(synCtx);
         else
             Axis2Sender.sendOn(synCtx);
+    }
+
+    public MessageContext createMessageContext() {
+        org.apache.axis2.context.MessageContext axis2MC = new 
org.apache.axis2.context.MessageContext();
+        MessageContext mc = new Axis2MessageContext(axis2MC, synapseConfig, 
this);
+        return mc;
     }
 
 }

Modified: 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/SynapseModule.java
URL: 
http://svn.apache.org/viewvc/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/SynapseModule.java?view=diff&rev=473678&r1=473677&r2=473678
==============================================================================
--- 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/SynapseModule.java
 (original)
+++ 
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/core/axis2/SynapseModule.java
 Sat Nov 11 01:56:10 2006
@@ -137,7 +137,7 @@
                 handleException("Error instantiating Synapse environment with 
: " + clazz, e);
             }
         } else {
-            synapseEnvParam.setValue(new Axis2SynapseEnvironment(cfgCtx));
+            synapseEnvParam.setValue(new Axis2SynapseEnvironment(cfgCtx, 
synapseConfiguration));
         }
 
         try {



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]