@@ -17,19 +17,19 @@ public class RedisExtensionConfigProvider : IExtensionConfigProvider
1717 {
1818 private readonly IConfiguration configuration ;
1919 private readonly INameResolver nameResolver ;
20- private readonly ILogger logger ;
20+ private readonly ILoggerFactory loggerFactory ;
2121
2222 /// <summary>
2323 /// Adds Redis triggers and bindings to the extension context.
2424 /// </summary>
2525 /// <param name="configuration"></param>
2626 /// <param name="nameResolver"></param>
27- /// <param name="logger "></param>
28- public RedisExtensionConfigProvider ( IConfiguration configuration , INameResolver nameResolver , ILogger logger )
27+ /// <param name="loggerFactory "></param>
28+ public RedisExtensionConfigProvider ( IConfiguration configuration , INameResolver nameResolver , ILoggerFactory loggerFactory )
2929 {
3030 this . configuration = configuration ;
3131 this . nameResolver = nameResolver ;
32- this . logger = logger ;
32+ this . loggerFactory = loggerFactory ;
3333 }
3434
3535 /// <summary>
@@ -44,15 +44,15 @@ public void Initialize(ExtensionConfigContext context)
4444
4545#pragma warning disable CS0618
4646 FluentBindingRule < RedisPubSubTriggerAttribute > pubsubTriggerRule = context . AddBindingRule < RedisPubSubTriggerAttribute > ( ) ;
47- pubsubTriggerRule . BindToTrigger < RedisPubSubMessage > ( new RedisPubSubTriggerBindingProvider ( configuration , nameResolver , logger ) ) ;
47+ pubsubTriggerRule . BindToTrigger < RedisPubSubMessage > ( new RedisPubSubTriggerBindingProvider ( configuration , nameResolver , loggerFactory . CreateLogger ( "RedisPubSubTrigger" ) ) ) ;
4848 pubsubTriggerRule . AddConverter < RedisPubSubMessage , string > ( message => message . Message ) ;
4949
5050 FluentBindingRule < RedisListTriggerAttribute > listsTriggerRule = context . AddBindingRule < RedisListTriggerAttribute > ( ) ;
51- listsTriggerRule . BindToTrigger < RedisListEntry > ( new RedisListTriggerBindingProvider ( configuration , nameResolver , logger ) ) ;
51+ listsTriggerRule . BindToTrigger < RedisListEntry > ( new RedisListTriggerBindingProvider ( configuration , nameResolver , loggerFactory . CreateLogger ( "RedisListTrigger" ) ) ) ;
5252 listsTriggerRule . AddConverter < RedisListEntry , string > ( listEntry => listEntry . Value ) ;
5353
5454 FluentBindingRule < RedisStreamTriggerAttribute > streamsTriggerRule = context . AddBindingRule < RedisStreamTriggerAttribute > ( ) ;
55- streamsTriggerRule . BindToTrigger < RedisStreamEntry > ( new RedisStreamTriggerBindingProvider ( configuration , nameResolver , logger ) ) ;
55+ streamsTriggerRule . BindToTrigger < RedisStreamEntry > ( new RedisStreamTriggerBindingProvider ( configuration , nameResolver , loggerFactory . CreateLogger ( "RedisStreamTrigger" ) ) ) ;
5656 streamsTriggerRule . AddConverter < RedisStreamEntry , KeyValuePair < string , string > [ ] > ( entry => entry . Values ) ;
5757 streamsTriggerRule . AddConverter < RedisStreamEntry , string > ( entry => JsonSerializer . Serialize ( entry . Values ) ) ;
5858 streamsTriggerRule . AddConverter < RedisStreamEntry , IReadOnlyDictionary < string , string > > ( entry => entry . Values . ToDictionary ( ) ) ;
0 commit comments