Skip to content

Commit

Permalink
v5.6 RedisStream支持按时间清理过期消息
Browse files Browse the repository at this point in the history
  • Loading branch information
nnhy committed Mar 4, 2024
1 parent b10d716 commit a2c5133
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 9 deletions.
2 changes: 1 addition & 1 deletion NewLife.Redis/FullRedis.cs
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ public void InitCluster()
}
else
{
WriteLog("InitCluster[{0}]:mode={1}, role={2}", Name, mode, role);
WriteLog("Init[{0}]:mode={1}, role={2}", Name, mode, role);

// 集群模式初始化节点
if (mode == "cluster")
Expand Down
4 changes: 2 additions & 2 deletions NewLife.Redis/NewLife.Redis.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
<RepositoryUrl>https://github.com/NewLifeX/NewLife.Redis</RepositoryUrl>
<RepositoryType>git</RepositoryType>
<PackageTags>新生命团队;X组件;NewLife;$(AssemblyName)</PackageTags>
<PackageReleaseNotes>支持集群中的批量操作</PackageReleaseNotes>
<PackageReleaseNotes>RedisStream支持按时间清理过期消息</PackageReleaseNotes>
<PackageLicenseExpression>MIT</PackageLicenseExpression>
<PublishRepositoryUrl>true</PublishRepositoryUrl>
<EmbedUntrackedSources>true</EmbedUntrackedSources>
Expand All @@ -46,7 +46,7 @@
</ItemGroup>

<ItemGroup>
<PackageReference Include="NewLife.Core" Version="10.7.2024.202" />
<PackageReference Include="NewLife.Core" Version="10.8.2024.303" />
</ItemGroup>

<ItemGroup>
Expand Down
2 changes: 1 addition & 1 deletion Test/Test.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
<PackageReference Include="Microsoft.AspNetCore.DataProtection.StackExchangeRedis" Version="8.0.0" />
<PackageReference Include="Microsoft.Extensions.Caching.Redis" Version="2.2.0" />
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="8.0.0" />
<PackageReference Include="NewLife.Core" Version="10.7.2024.202" />
<PackageReference Include="NewLife.Core" Version="10.8.2024.303" />
</ItemGroup>

<ItemGroup>
Expand Down
2 changes: 2 additions & 0 deletions XUnitTest/Queues/QueueTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -164,6 +164,8 @@ public void Queue_Benchmark()
{
var key = "Queue_benchmark";

_redis.Remove(key);

var q = _redis.GetQueue<String>(key);
for (var i = 0; i < 1_000; i++)
{
Expand Down
10 changes: 5 additions & 5 deletions XUnitTest/XUnitTest.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -3,17 +3,17 @@
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<OutputPath>..\Bin\UnitTest</OutputPath>

<SatelliteResourceLanguages>en</SatelliteResourceLanguages>
<IsPackable>false</IsPackable>
</PropertyGroup>

<ItemGroup>
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="8.0.0" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.8.0" />
<PackageReference Include="NewLife.Core" Version="10.7.2024.202" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.9.0" />
<PackageReference Include="NewLife.Core" Version="10.8.2024.303" />
<PackageReference Include="NewLife.UnitTest" Version="1.0.2023.1204" />
<PackageReference Include="xunit" Version="2.6.6" />
<PackageReference Include="xunit.runner.visualstudio" Version="2.5.6">
<PackageReference Include="xunit" Version="2.7.0" />
<PackageReference Include="xunit.runner.visualstudio" Version="2.5.7">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
Expand Down

0 comments on commit a2c5133

Please sign in to comment.