async afterCreateMessageBrokerServiceBase(
context: DsgContext,
eventParams: CreateMessageBrokerServiceBaseParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const { messageBrokerDirectory } = serverDirectories;
const filePath = resolve(staticDirectory, `kafka.service.base.ts`);
const file = await readFile(filePath, "utf8");
const generateFileName = `kafka.service.base.ts`;
const path = join(messageBrokerDirectory, "base", generateFileName);
modules.set({ code: file, path });
return modules;
}
Creates the base service of the Kafka message broker.
async afterCreateMessageBrokerServiceBase(
context: DsgContext,
eventParams: CreateMessageBrokerServiceBaseParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const { messageBrokerDirectory } = serverDirectories;
const filePath = resolve(staticDirectory, `kafka.service.base.ts`);
const file = await readFile(filePath, "utf8");
const generateFileName = `kafka.service.base.ts`;
const path = join(messageBrokerDirectory, "base", generateFileName);
modules.set({ code: file, path });
return modules;
}
CreateMessageBrokerServiceBase
async afterCreateMessageBrokerServiceBase(
context: DsgContext,
eventParams: CreateMessageBrokerServiceBaseParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const { messageBrokerDirectory } = serverDirectories;
const filePath = resolve(staticDirectory, `kafka.service.base.ts`);
const file = await readFile(filePath, "utf8");
const generateFileName = `kafka.service.base.ts`;
const path = join(messageBrokerDirectory, "base", generateFileName);
modules.set({ code: file, path });
return modules;
}
Was this page helpful?