async afterCreateMessageBrokerNestJSModule(
    context: DsgContext,
    eventParams: CreateMessageBrokerNestJSModuleParams,
    modules: ModuleMap
  ) {
    const filePath = resolve(staticDirectory, "kafka.module.ts");

    const { serverDirectories } = context;
    const { messageBrokerDirectory } = serverDirectories;
    const file = await readFile(filePath, "utf8");
    const generateFileName = "kafka.module.ts";

    this.moduleFile = {
      code: file,
      path: join(messageBrokerDirectory, generateFileName),
    };

    return modules.set(this.moduleFile);
  }

​
Event Name

CreateMessageBrokerNestJSModule

​
Event Parameters

This event does not use additional parameters.

  async afterCreateMessageBrokerNestJSModule(
    context: DsgContext,
    eventParams: CreateMessageBrokerNestJSModuleParams,
    modules: ModuleMap
  ) {
    const filePath = resolve(staticDirectory, "kafka.module.ts");

    const { serverDirectories } = context;
    const { messageBrokerDirectory } = serverDirectories;
    const file = await readFile(filePath, "utf8");
    const generateFileName = "kafka.module.ts";

    this.moduleFile = {
      code: file,
      path: join(messageBrokerDirectory, generateFileName),
    };

    return modules.set(this.moduleFile);
  }

This event does NOTHING by default. All of the logic is handled by the broker-kafka plugin.

  async afterCreateMessageBrokerNestJSModule(
    context: DsgContext,
    eventParams: CreateMessageBrokerNestJSModuleParams,
    modules: ModuleMap
  ) {
    const filePath = resolve(staticDirectory, "kafka.module.ts");

    const { serverDirectories } = context;
    const { messageBrokerDirectory } = serverDirectories;
    const file = await readFile(filePath, "utf8");
    const generateFileName = "kafka.module.ts";

    this.moduleFile = {
      code: file,
      path: join(messageBrokerDirectory, generateFileName),
    };

    return modules.set(this.moduleFile);
  }

​
Event Name

CreateMessageBrokerNestJSModule

​
Event Parameters

This event does not use additional parameters.

  async afterCreateMessageBrokerNestJSModule(
    context: DsgContext,
    eventParams: CreateMessageBrokerNestJSModuleParams,
    modules: ModuleMap
  ) {
    const filePath = resolve(staticDirectory, "kafka.module.ts");

    const { serverDirectories } = context;
    const { messageBrokerDirectory } = serverDirectories;
    const file = await readFile(filePath, "utf8");
    const generateFileName = "kafka.module.ts";

    this.moduleFile = {
      code: file,
      path: join(messageBrokerDirectory, generateFileName),
    };

    return modules.set(this.moduleFile);
  }

This event does NOTHING by default. All of the logic is handled by the broker-kafka plugin.