diff --git a/libraries/module-tools/src/ManagedModule.ts b/libraries/module-tools/src/ManagedModule.ts index ec45088af..f0814fd20 100644 --- a/libraries/module-tools/src/ManagedModule.ts +++ b/libraries/module-tools/src/ManagedModule.ts @@ -9,9 +9,8 @@ import ConduitGrpcSdk, { SetConfigRequest, SetConfigResponse, } from '@conduitplatform/grpc-sdk'; -import { merge } from './utilities'; +import { initializeSdk, merge } from './utilities'; import { convictConfigParser } from './utilities/convictConfigParser'; -import { initializeSdk } from './utilities/initializeSdk'; import { RoutingManager } from './routing'; import { RoutingController } from './routing/RoutingController'; import { ModuleLifecycleStage } from './interfaces/ModuleLifecycleStage'; @@ -219,10 +218,13 @@ export abstract class ManagedModule extends ConduitServiceModule { /** Used to update the module's configuration on initial Redis/DB reconciliation. */ async handleConfigSyncUpdate() { if (!this.config) return; - this.grpcSdk.bus!.subscribe(`${this.name}:config:update`, async (message: string) => { - ConfigController.getInstance().config = await this.preConfig(JSON.parse(message)); - await this.onConfig(); - }); + this.grpcSdk.bus!.subscribe( + `${kebabCase(this.name)}:config:update`, + async (message: string) => { + ConfigController.getInstance().config = await this.preConfig(JSON.parse(message)); + await this.onConfig(); + }, + ); } private async preRegisterLifecycle(): Promise {