Creates the client options of the message broker.
async afterCreateMessageBrokerClientOptionsFactory(
context: DsgContext,
eventParams: CreateMessageBrokerClientOptionsFactoryParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const filePath = resolve(staticDirectory, "generateKafkaClientOptions.ts");
const file = await readFile(filePath, "utf8");
const generateFileName = "generateKafkaClientOptions.ts";
const path = join(
serverDirectories.messageBrokerDirectory,
generateFileName
);
modules.set({ code: file, path });
return modules;
}
CreateMessageBrokerClientOptionsFactory
This event does not use additional parameters.
async afterCreateMessageBrokerClientOptionsFactory(
context: DsgContext,
eventParams: CreateMessageBrokerClientOptionsFactoryParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const filePath = resolve(staticDirectory, "generateKafkaClientOptions.ts");
const file = await readFile(filePath, "utf8");
const generateFileName = "generateKafkaClientOptions.ts";
const path = join(
serverDirectories.messageBrokerDirectory,
generateFileName
);
modules.set({ code: file, path });
return modules;
}
This event does NOTHING by default. All of the logic is handled by the broker-kafka plugin.
Was this page helpful?
async afterCreateMessageBrokerClientOptionsFactory(
context: DsgContext,
eventParams: CreateMessageBrokerClientOptionsFactoryParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const filePath = resolve(staticDirectory, "generateKafkaClientOptions.ts");
const file = await readFile(filePath, "utf8");
const generateFileName = "generateKafkaClientOptions.ts";
const path = join(
serverDirectories.messageBrokerDirectory,
generateFileName
);
modules.set({ code: file, path });
return modules;
}
Creates the client options of the message broker.
async afterCreateMessageBrokerClientOptionsFactory(
context: DsgContext,
eventParams: CreateMessageBrokerClientOptionsFactoryParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const filePath = resolve(staticDirectory, "generateKafkaClientOptions.ts");
const file = await readFile(filePath, "utf8");
const generateFileName = "generateKafkaClientOptions.ts";
const path = join(
serverDirectories.messageBrokerDirectory,
generateFileName
);
modules.set({ code: file, path });
return modules;
}
CreateMessageBrokerClientOptionsFactory
This event does not use additional parameters.
async afterCreateMessageBrokerClientOptionsFactory(
context: DsgContext,
eventParams: CreateMessageBrokerClientOptionsFactoryParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const filePath = resolve(staticDirectory, "generateKafkaClientOptions.ts");
const file = await readFile(filePath, "utf8");
const generateFileName = "generateKafkaClientOptions.ts";
const path = join(
serverDirectories.messageBrokerDirectory,
generateFileName
);
modules.set({ code: file, path });
return modules;
}
This event does NOTHING by default. All of the logic is handled by the broker-kafka plugin.
Was this page helpful?
async afterCreateMessageBrokerClientOptionsFactory(
context: DsgContext,
eventParams: CreateMessageBrokerClientOptionsFactoryParams,
modules: ModuleMap
): Promise<ModuleMap> {
const { serverDirectories } = context;
const filePath = resolve(staticDirectory, "generateKafkaClientOptions.ts");
const file = await readFile(filePath, "utf8");
const generateFileName = "generateKafkaClientOptions.ts";
const path = join(
serverDirectories.messageBrokerDirectory,
generateFileName
);
modules.set({ code: file, path });
return modules;
}