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