|
32 | 32 | import org.wso2.carbon.mediation.initializer.ServiceBusUtils;
|
33 | 33 | import org.wso2.carbon.mediation.initializer.services.SynapseEnvironmentService;
|
34 | 34 | import org.wso2.carbon.mediation.initializer.services.SynapseRegistrationsService;
|
35 |
| -import org.wso2.carbon.proxyadmin.observer.ProxyObserver; |
36 | 35 | import org.wso2.carbon.proxyadmin.observer.ProxyServiceParameterObserver;
|
37 | 36 | import org.wso2.carbon.proxyadmin.service.ProxyDeployerService;
|
38 | 37 | import org.wso2.carbon.proxyadmin.service.ProxyDeployerServiceImpl;
|
39 | 38 | import org.wso2.carbon.proxyadmin.util.ConfigHolder;
|
40 |
| -import org.wso2.carbon.registry.core.exceptions.RegistryException; |
41 | 39 | import org.wso2.carbon.registry.core.service.RegistryService;
|
42 | 40 | import org.wso2.carbon.service.mgt.ServiceAdmin;
|
43 | 41 | import org.wso2.carbon.utils.AbstractAxis2ConfigurationContextObserver;
|
@@ -86,14 +84,6 @@ protected void activate(ComponentContext context) {
|
86 | 84 | if (synEnvService != null) {
|
87 | 85 | AxisConfiguration axisConf = synEnvService.getConfigurationContext().getAxisConfiguration();
|
88 | 86 | try {
|
89 |
| - if (!Boolean.parseBoolean(System.getProperty("NonRegistryMode"))) { |
90 |
| - ProxyObserver proxyObserver = new ProxyObserver(synEnvService, ConfigHolder.getInstance() |
91 |
| - .getRegistryService().getConfigSystemRegistry()); |
92 |
| - ConfigHolder.getInstance().addProxyObserver(MultitenantConstants.SUPER_TENANT_ID, |
93 |
| - proxyObserver); |
94 |
| - axisConf.addObservers(proxyObserver); |
95 |
| - proxyObserver.setSynapseEnvironmentService(synEnvService); |
96 |
| - } |
97 | 87 | registerDeployer(synEnvService.getConfigurationContext().getAxisConfiguration(), synEnvService
|
98 | 88 | .getSynapseEnvironment());
|
99 | 89 | bindProxyParameterObserver(axisConf);
|
@@ -179,24 +169,12 @@ protected void setSynapseEnvironmentService(SynapseEnvironmentService synapseEnv
|
179 | 169 | int tenantId = synapseEnvironmentService.getTenantId();
|
180 | 170 | AxisConfiguration axisConfiguration = synapseEnvironmentService.getConfigurationContext()
|
181 | 171 | .getAxisConfiguration();
|
182 |
| - ProxyObserver observer; |
183 | 172 | if (!alreadyCreated) {
|
184 | 173 | try {
|
185 | 174 | registerDeployer(synapseEnvironmentService.getConfigurationContext().getAxisConfiguration(),
|
186 | 175 | synapseEnvironmentService.getSynapseEnvironment());
|
187 |
| - observer = new ProxyObserver(synapseEnvironmentService, ConfigHolder.getInstance() |
188 |
| - .getRegistryService().getConfigSystemRegistry(tenantId)); |
189 |
| - axisConfiguration.addObservers(observer); |
190 |
| - ConfigHolder.getInstance().addProxyObserver(tenantId, observer); |
191 | 176 | } catch (ProxyAdminException e) {
|
192 | 177 | log.error("Error while initializing the proxy admin.", e);
|
193 |
| - } catch (RegistryException e) { |
194 |
| - log.error("Error while initializing the proxy admin.", e); |
195 |
| - } |
196 |
| - } else { |
197 |
| - observer = ConfigHolder.getInstance().getProxyObsever(tenantId); |
198 |
| - if (observer != null) { |
199 |
| - observer.setSynapseEnvironmentService(synapseEnvironmentService); |
200 | 178 | }
|
201 | 179 | }
|
202 | 180 | }
|
@@ -303,12 +281,7 @@ public void createdConfigurationContext(ConfigurationContext configContext) {
|
303 | 281 | SynapseEnvironmentService synEnvService = ConfigHolder.getInstance().getSynapseEnvironmentService
|
304 | 282 | (tenantId);
|
305 | 283 | if (synEnvService != null) {
|
306 |
| - ProxyObserver proxyObserver = new ProxyObserver(synEnvService, ConfigHolder.getInstance() |
307 |
| - .getRegistryService().getConfigSystemRegistry(tenantId)); |
308 |
| - ConfigHolder.getInstance().addProxyObserver(tenantId, proxyObserver); |
309 |
| - axisConfig.addObservers(proxyObserver); |
310 | 284 | registerDeployer(axisConfig, synEnvService.getSynapseEnvironment());
|
311 |
| - proxyObserver.setSynapseEnvironmentService(synEnvService); |
312 | 285 | }
|
313 | 286 | } else {
|
314 | 287 | log.error("Error while initialzing AxisConfiguration", null);
|
|
0 commit comments