Skip to content

Commit a828299

Browse files
committed
v0.5.0 fix: RecoverySentinel
1 parent 1cbe829 commit a828299

File tree

3 files changed

+16
-2
lines changed

3 files changed

+16
-2
lines changed

examples/console_netcore31_sentinel/Program.cs

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,13 +14,26 @@ class Program
1414
var r = new RedisClient("mymaster,default=3", new[] { "127.0.0.1:26379", "127.0.0.1:26479", "127.0.0.1:26579" }, false);
1515
r.Serialize = obj => JsonConvert.SerializeObject(obj);
1616
r.Deserialize = (json, type) => JsonConvert.DeserializeObject(json, type);
17-
//r.Notice += (s, e) => Trace.WriteLine(e.Log);
17+
r.Notice += (s, e) => Console.WriteLine(e.Log);
1818
return r;
1919
});
2020
static RedisClient cli => _cliLazy.Value;
2121

2222
static void Main(string[] args)
2323
{
24+
while (Console.ReadKey().Key == ConsoleKey.Enter)
25+
{
26+
try
27+
{
28+
cli.Get(Guid.NewGuid().ToString());
29+
}
30+
catch (Exception ex)
31+
{
32+
Console.WriteLine(ex.Message);
33+
}
34+
}
35+
36+
return;
2437

2538
for (var k = 0; k < 1; k++)
2639
{

src/FreeRedis/FreeRedis.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<AssemblyName>FreeRedis</AssemblyName>
66
<PackageId>FreeRedis</PackageId>
77
<RootNamespace>FreeRedis</RootNamespace>
8-
<Version>0.3.7</Version>
8+
<Version>0.5.0</Version>
99
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
1010
<PackageProjectUrl>https://github.com/2881099/FreeRedis</PackageProjectUrl>
1111
<Description>FreeRedis is .NET redis client, supports cluster, sentinel, master-slave, pipeline, transaction and connection pool.</Description>

src/FreeRedis/RedisClient/Adapter/SentinelAdapter.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,7 @@ public override TValue AdapterCall<TValue>(CommandPacket cmd, Func<RedisResult,
106106
var pool = (rds as DefaultRedisSocket.TempProxyRedisSocket)._pool;
107107
if (pool?.SetUnavailable(ex) == true)
108108
{
109+
RecoverySentinel();
109110
}
110111
throw;
111112
}

0 commit comments

Comments
 (0)