SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

remove retry

Browse source
This commit is contained in:
Haiping Chen 2024-12-17 06:37:18 +00:00
parent 3c4821c368
commit 067a701ff1
1 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisPublisher.cs
View file

@ -79,14 +79,13 @@ public class RedisPublisher : IEventPublisher
return exists;
}
private NameValueEntry[] AssembleMessage(RedisValue message, int retry = 0)
private NameValueEntry[] AssembleMessage(RedisValue message)
{
return
[
new NameValueEntry("message", message),
new NameValueEntry("timestamp", DateTime.UtcNow.ToString("o")),
new NameValueEntry("machine", Environment.MachineName),
new NameValueEntry("retry", retry),
new NameValueEntry("machine", Environment.MachineName)
];
}
@ -102,10 +101,8 @@ public class RedisPublisher : IEventPublisher
try
{
var message = entry.Values.First(x => x.Name == "message").Value;
var retryKv = entry.Values.FirstOrDefault(x => x.Name == "retry");
int.TryParse(retryKv.Value, out int retry);
var messageId = await db.StreamAddAsync(channel,
AssembleMessage(message, retry: retry + 1),
AssembleMessage(message),
maxLength: 1000 * 10000);
_logger.LogWarning($"ReDispatched message: {channel} {entry.Values[0].Value} ({messageId})");