Merge pull request #17 from auke-/fix-notify-when-proxy-started

Notify observers when starting proxy services

Author: isudana

modules/core/src/main/java/org/apache/synapse/Axis2SynapseController.java

@@ -475,28 +475,26 @@ public void stop() {
      * @return SynapseEnvironment instance
      */
     public SynapseEnvironment createSynapseEnvironment() {
-
-        try {
-            deploySynapseService();
-            deployProxyServices();
-            deployEventSources();
-        } catch (AxisFault axisFault) {
-            log.fatal("Synapse startup failed...", axisFault);
-            throw new SynapseException("Synapse startup failed", axisFault);
-        }
-
         synapseEnvironment = new Axis2SynapseEnvironment(
-                configurationContext, synapseConfiguration, serverContextInformation);
+            configurationContext, synapseConfiguration, serverContextInformation);
         MessageContextCreatorForAxis2.setSynEnv(synapseEnvironment);
 
         Parameter synapseEnvironmentParameter = new Parameter(
-                SynapseConstants.SYNAPSE_ENV, synapseEnvironment);
+            SynapseConstants.SYNAPSE_ENV, synapseEnvironment);
         try {
             configurationContext.getAxisConfiguration().addParameter(synapseEnvironmentParameter);
         } catch (AxisFault e) {
             handleFatal("Could not set parameter '" + SynapseConstants.SYNAPSE_ENV +
-                    "' to the Axis2 configuration : " + e.getMessage(), e);
+                "' to the Axis2 configuration : " + e.getMessage(), e);
+        }
 
+        try {
+            deploySynapseService();
+            deployProxyServices();
+            deployEventSources();
+        } catch (AxisFault axisFault) {
+            log.fatal("Synapse startup failed...", axisFault);
+            throw new SynapseException("Synapse startup failed", axisFault);
         }
 
         synapseEnvironment.getTaskManager().init(taskDescriptionRepository, taskScheduler);
@@ -778,7 +776,9 @@ private void deployProxyServices() {
                         configurationContext.getAxisConfiguration());
                 if (proxyService != null) {
                     log.info("Deployed Proxy service : " + proxy.getName());
-                    if (!proxy.isStartOnLoad()) {
+                    if (proxy.isStartOnLoad()) {
+                        proxy.start(synapseConfiguration);
+                    } else {
                         proxy.stop(synapseConfiguration);
                     }
                 } else {

modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyService.java

@@ -577,7 +577,6 @@ public AxisService buildAxisService(SynapseConfiguration synCfg, AxisConfigurati
                     axisCfg.addServiceToExistingServiceGroup(proxyService, serviceGroup);
                 }
             }
-            this.setRunning(true);
         } catch (AxisFault axisFault) {
             try {
                 if (axisCfg.getService(proxyService.getName()) != null) {