diff --git a/src/NRedisStack/Auxiliary.cs b/src/NRedisStack/Auxiliary.cs index ffac0e27..c336431d 100644 --- a/src/NRedisStack/Auxiliary.cs +++ b/src/NRedisStack/Auxiliary.cs @@ -48,30 +48,28 @@ public static IDatabase GetDatabase(this ConnectionMultiplexer redis, return _db; } - private static void SetInfoInPipeline(this IDatabase db) + internal static void SetInfoInPipeline(this IDatabase db) { - if (_libraryName == null) return; - Pipeline pipeline = new Pipeline(db); - _ = pipeline.Db.ClientSetInfoAsync(SetInfoAttr.LibraryName, _libraryName!); - _ = pipeline.Db.ClientSetInfoAsync(SetInfoAttr.LibraryVersion, GetNRedisStackVersion()); - pipeline.Execute(); + if (_setInfo) + { + _setInfo = false; + if (_libraryName == null) return; + Pipeline pipeline = new Pipeline(db); + _ = pipeline.Db.ClientSetInfoAsync(SetInfoAttr.LibraryName, _libraryName!); + _ = pipeline.Db.ClientSetInfoAsync(SetInfoAttr.LibraryVersion, GetNRedisStackVersion()); + pipeline.Execute(); + } } public static RedisResult Execute(this IDatabase db, SerializedCommand command) { - if (!_setInfo) return db.Execute(command.Command, command.Args); - _setInfo = false; db.SetInfoInPipeline(); return db.Execute(command.Command, command.Args); } public static async Task ExecuteAsync(this IDatabaseAsync db, SerializedCommand command) { - if (_setInfo) - { - _setInfo = false; - ((IDatabase)db).SetInfoInPipeline(); - } + ((IDatabase)db).SetInfoInPipeline(); return await db.ExecuteAsync(command.Command, command.Args); } diff --git a/src/NRedisStack/Transactions.cs b/src/NRedisStack/Transactions.cs index b14e68de..74eb89ae 100644 --- a/src/NRedisStack/Transactions.cs +++ b/src/NRedisStack/Transactions.cs @@ -9,6 +9,7 @@ public class Transaction public Transaction(IDatabase db) { + db.SetInfoInPipeline(); _transaction = db.CreateTransaction(); }