afterCreateMessageBrokerClientOptionsFactory(
context: dotnetTypes.DsgContext,
eventParams: dotnet.CreateMessageBrokerClientOptionsFactoryParams,
files: FileMap<Class>
): Promise<FileMap<Class>> {
const optionsFactoryFile = files.get("MessageBroker/MessageBrokerClientOptionsFactory.cs");
if (optionsFactoryFile) {
optionsFactoryFile.code.addMethod(
CsharpSupport.method({
name: "CreateConsumerConfig",
access: "public",
returnType: CsharpSupport.Types.reference("ConsumerConfig"),
body: `return new ConsumerConfig { GroupId = "my-consumer-group" };`,
})
);
}
return files;
}
Creates the client options factory for the message broker.
afterCreateMessageBrokerClientOptionsFactory(
context: dotnetTypes.DsgContext,
eventParams: dotnet.CreateMessageBrokerClientOptionsFactoryParams,
files: FileMap<Class>
): Promise<FileMap<Class>> {
const optionsFactoryFile = files.get("MessageBroker/MessageBrokerClientOptionsFactory.cs");
if (optionsFactoryFile) {
optionsFactoryFile.code.addMethod(
CsharpSupport.method({
name: "CreateConsumerConfig",
access: "public",
returnType: CsharpSupport.Types.reference("ConsumerConfig"),
body: `return new ConsumerConfig { GroupId = "my-consumer-group" };`,
})
);
}
return files;
}
CreateMessageBrokerClientOptionsFactory
afterCreateMessageBrokerClientOptionsFactory(
context: dotnetTypes.DsgContext,
eventParams: dotnet.CreateMessageBrokerClientOptionsFactoryParams,
files: FileMap<Class>
): Promise<FileMap<Class>> {
const optionsFactoryFile = files.get("MessageBroker/MessageBrokerClientOptionsFactory.cs");
if (optionsFactoryFile) {
optionsFactoryFile.code.addMethod(
CsharpSupport.method({
name: "CreateConsumerConfig",
access: "public",
returnType: CsharpSupport.Types.reference("ConsumerConfig"),
body: `return new ConsumerConfig { GroupId = "my-consumer-group" };`,
})
);
}
return files;
}
Was this page helpful?