Creates the NestJS of the message broker.
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);
}
CreateMessageBrokerNestJSModule
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.
Was this page helpful?
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);
}
Creates the NestJS of the message broker.
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);
}
CreateMessageBrokerNestJSModule
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.
Was this page helpful?
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);
}