You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ru...@apache.org on 2009/04/25 21:02:08 UTC
svn commit: r768583 - in
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse:
Axis2SynapseController.java ServerContextInformation.java ServerManager.java
Author: ruwan
Date: Sat Apr 25 19:02:08 2009
New Revision: 768583
URL: http://svn.apache.org/viewvc?rev=768583&view=rev
Log:
ServerContextInformation should contain the SynapseConfiguration and the SynapseEnvironment
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Axis2SynapseController.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerContextInformation.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Axis2SynapseController.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Axis2SynapseController.java?rev=768583&r1=768582&r2=768583&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Axis2SynapseController.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Axis2SynapseController.java Sat Apr 25 19:02:08 2009
@@ -84,9 +84,9 @@
/**
* Initiates the Axis2 Based Server Environment
*
- * @param configurationInformation ServerConfigurationInformation Instance
- * @param contextInformation Server Context if the Axis2 Based Server
- * Environment has been already set up.
+ * @param serverConfigurationInformation ServerConfigurationInformation Instance
+ * @param contextInformation Server Context if the Axis2 Based Server Environment has been
+ * already set up.
*/
public void init(ServerConfigurationInformation serverConfigurationInformation,
ServerContextInformation contextInformation) {
@@ -189,7 +189,7 @@
listenerManager.start();
} else {
handleFatal("Couldn't start Synapse, ListenerManager not found");
- }
+ }
/* if JMX Adapter has been configured and started, output usage information rather
at the end of the startup process to make it more obvious */
if (jmxAdapter != null && jmxAdapter.isRunning()) {
@@ -277,13 +277,12 @@
throw new SynapseException("Synapse startup failed", axisFault);
}
- Parameter synapseEnvironmentParameter = new Parameter(SynapseConstants.SYNAPSE_ENV, null);
synapseEnvironment = new Axis2SynapseEnvironment(
configurationContext, synapseConfiguration);
- synapseEnvironmentParameter.setValue(synapseEnvironment);
-
MessageContextCreatorForAxis2.setSynEnv(synapseEnvironment);
-
+
+ Parameter synapseEnvironmentParameter = new Parameter(
+ SynapseConstants.SYNAPSE_ENV, synapseEnvironment);
try {
configurationContext.getAxisConfiguration().addParameter(synapseEnvironmentParameter);
} catch (AxisFault e) {
@@ -318,13 +317,11 @@
// Set the Axis2 ConfigurationContext to the SynapseConfiguration
synapseConfiguration.setAxisConfiguration(configurationContext.getAxisConfiguration());
-
- // set the Synapse configuration and environment into the Axis2 configuration
- Parameter synapseConfigurationParameter = new Parameter(
- SynapseConstants.SYNAPSE_CONFIG, null);
- synapseConfigurationParameter.setValue(synapseConfiguration);
MessageContextCreatorForAxis2.setSynConfig(synapseConfiguration);
+ // set the Synapse configuration into the Axis2 configuration
+ Parameter synapseConfigurationParameter = new Parameter(
+ SynapseConstants.SYNAPSE_CONFIG, synapseConfiguration);
try {
configurationContext.getAxisConfiguration().addParameter(synapseConfigurationParameter);
} catch (AxisFault e) {
@@ -533,6 +530,8 @@
if (taskHelper.isInitialized()) {
taskHelper.cleanup();
}
+
+ stopJmxAdapter();
}
private void addDefaultBuildersAndFormatters(AxisConfiguration axisConf) {
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerContextInformation.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerContextInformation.java?rev=768583&r1=768582&r2=768583&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerContextInformation.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerContextInformation.java Sat Apr 25 19:02:08 2009
@@ -18,6 +18,9 @@
*/
package org.apache.synapse;
+import org.apache.synapse.config.SynapseConfiguration;
+import org.apache.synapse.core.SynapseEnvironment;
+
import java.util.HashMap;
import java.util.Map;
@@ -30,6 +33,10 @@
private Object serverContext;
/* A map to hold any context information*/
private final Map<String, Object> properties = new HashMap<String, Object>();
+ /* Keeps the SynapseConfiguration */
+ private SynapseConfiguration synapseConfiguration;
+ /* Keeps the SynapseEnvironment */
+ private SynapseEnvironment synapseEnvironment;
private ServerState serverState = ServerState.UNDETERMINED;
@@ -63,4 +70,20 @@
public void setServerState(ServerState serverState) {
this.serverState = serverState;
}
+
+ public SynapseConfiguration getSynapseConfiguration() {
+ return synapseConfiguration;
+ }
+
+ public void setSynapseConfiguration(SynapseConfiguration synapseConfiguration) {
+ this.synapseConfiguration = synapseConfiguration;
+ }
+
+ public SynapseEnvironment getSynapseEnvironment() {
+ return synapseEnvironment;
+ }
+
+ public void setSynapseEnvironment(SynapseEnvironment synapseEnvironment) {
+ this.synapseEnvironment = synapseEnvironment;
+ }
}
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java?rev=768583&r1=768582&r2=768583&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java Sat Apr 25 19:02:08 2009
@@ -273,9 +273,11 @@
if (serverState == ServerState.INITIALIZED || serverState == ServerState.STOPPED) {
// creates the Synapse Configuration using the SynapseController
- synapseController.createSynapseConfiguration();
+ contextInformation.setSynapseConfiguration(
+ synapseController.createSynapseConfiguration());
// creates the Synapse Environment using the SynapseController
- synapseController.createSynapseEnvironment();
+ contextInformation.setSynapseEnvironment(
+ synapseController.createSynapseEnvironment());
// starts the SynapseController
synapseController.start();
@@ -301,8 +303,10 @@
synapseController.stop();
// destroy the created Synapse Configuration
synapseController.destroySynapseConfiguration();
+ contextInformation.setSynapseConfiguration(null);
// destroy the created Synapse Environment
synapseController.destroySynapseEnvironment();
+ contextInformation.setSynapseEnvironment(null);
chanageState(ServerState.STOPPED);
} else {