10 references to ConsumerConnectionFactoryStringKeyStringValueType
Aspire.Confluent.Kafka.Tests (10)
ConsumerConfigurationTests.cs (10)
39
? host.Services.GetRequiredKeyedService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value, "messaging")
40
: host.Services.GetRequiredService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value);
72
? host.Services.GetRequiredKeyedService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value, "messaging")
73
: host.Services.GetRequiredService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value);
105
? host.Services.GetRequiredKeyedService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value, "messaging")
106
: host.Services.GetRequiredService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value);
184
? host.Services.GetRequiredKeyedService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value, "messaging")
185
: host.Services.GetRequiredService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value);
253
var connectionFactory = host.Services.GetRequiredService(ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value);
265
private static ConsumerConfig? GetConsumerConfig(object o) => ReflectionHelpers.
ConsumerConnectionFactoryStringKeyStringValueType
.Value.GetProperty("Config")!.GetValue(o) as ConsumerConfig;