From 725672ade94a6807f11b8b6e7cffe25b1b82ceae Mon Sep 17 00:00:00 2001
From: Gorka Benguria <gorka.benguria@tecnalia.com>
Date: Thu, 3 Nov 2022 16:37:53 +0100
Subject: [PATCH] fix configservice for rxStomp
---
.../simulation-wizard.module.ts | 22 ++++++++++++++-----
1 file changed, 16 insertions(+), 6 deletions(-)
diff --git a/src/app/pages/simulation-wizard/simulation-wizard.module.ts b/src/app/pages/simulation-wizard/simulation-wizard.module.ts
index 360e4344..caddaef5 100644
--- a/src/app/pages/simulation-wizard/simulation-wizard.module.ts
+++ b/src/app/pages/simulation-wizard/simulation-wizard.module.ts
@@ -49,11 +49,20 @@ import { ExistingSimulationsComponent } from "./existing-simulations/existing-si
import { MlModuleComponent } from "./ml-module/ml-module.component";
import { RecommenderPageComponent } from "./recommender-page/recommender-page.component";
import { EditNetworkMapComponent } from "./edit-network-map/edit-network-map.component";
+import { ConfigService } from '@ngx-config/core';
-const rxStompConfig: InjectableRxStompConfig = {
- brokerURL: environment.baseStompURL,
- debug: (msg) => environment.showWebSocketDebug && console.debug(msg),
-};
+export class MyRxStompConfig extends InjectableRxStompConfig {
+ constructor(private configService: ConfigService) {
+ super();
+ this.brokerURL = `${configService.getSettings("traffic_simulation_stomp_url")}`;
+ this.heartbeatIncoming = 0;
+ this.heartbeatOutgoing = 10000;
+ this.reconnectDelay = 500;
+ this.debug = (msg: string): void => {
+ environment.showWebSocketDebug && console.debug(msg);
+ };
+ }
+}
@NgModule({
imports: [
@@ -102,8 +111,9 @@ const rxStompConfig: InjectableRxStompConfig = {
],
providers: [
{
- provide: InjectableRxStompConfig,
- useValue: rxStompConfig,
+ provide: InjectableRxStompConfig,
+ useClass: MyRxStompConfig,
+ deps: [ConfigService]
},
{
provide: RxStompService,
--
GitLab