Skip to content

Commit 910ae2f

Browse files
author
Sharifuzzaman Nakib
committed
Merge branch 'develop' of https://github.com/S-Nakib/OpenTransit into develop
2 parents e87d1d4 + b75785e commit 910ae2f

2 files changed

Lines changed: 18 additions & 17 deletions

File tree

‎Directory.Packages.props‎

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -10,32 +10,32 @@
1010
<PackageVersion Include="AWSSDK.S3" Version="4.0.7.4" />
1111
<PackageVersion Include="AWSSDK.SQS" Version="4.0.1.5" />
1212
<PackageVersion Include="Azure.Data.Tables" Version="12.11.0" />
13-
<PackageVersion Include="Azure.Identity" Version="1.16.0" />
13+
<PackageVersion Include="Azure.Identity" Version="1.17.1" />
1414
<PackageVersion Include="Azure.Messaging.EventHubs.Processor" Version="5.12.2" />
1515
<PackageVersion Include="Azure.Messaging.ServiceBus" Version="7.20.1" />
16-
<PackageVersion Include="Azure.Storage.Blobs" Version="12.25.0" />
16+
<PackageVersion Include="Azure.Storage.Blobs" Version="12.26.0" />
1717
<PackageVersion Include="BenchmarkDotNet" Version="0.13.11" />
18-
<PackageVersion Include="Confluent.Kafka" Version="2.11.1" />
19-
<PackageVersion Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.11.1" />
18+
<PackageVersion Include="Confluent.Kafka" Version="2.12.0" />
19+
<PackageVersion Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.12.0" />
2020
<PackageVersion Include="coverlet.collector" Version="3.1.2" />
2121
<PackageVersion Include="Dapper" Version="2.1.66" />
2222
<PackageVersion Include="dapper.contrib" Version="2.0.78" />
2323
<PackageVersion Include="EntityFramework" Version="6.5.1" />
2424
<PackageVersion Include="Google.Protobuf" Version="3.31.1" />
25-
<PackageVersion Include="Hangfire.AspNetCore" Version="1.8.21" />
26-
<PackageVersion Include="Hangfire.Core" Version="1.8.21" />
25+
<PackageVersion Include="Hangfire.AspNetCore" Version="1.8.22" />
26+
<PackageVersion Include="Hangfire.Core" Version="1.8.22" />
2727
<PackageVersion Include="Hangfire.MemoryStorage" Version="1.8.1.2" />
2828
<PackageVersion Include="Iesi.Collections" Version="4.1.1" />
2929
<PackageVersion Include="Ionic.Zlib.Core" Version="1.0.0" />
30-
<PackageVersion Include="Marten" Version="8.10.0" />
30+
<PackageVersion Include="Marten" Version="8.16.1" />
3131
<PackageVersion Include="MathNet.Numerics" Version="5.0.0" />
3232
<PackageVersion Include="MediatR" Version="12.2.0" />
3333
<PackageVersion Include="MessagePack" Version="3.1.4" />
3434
<PackageVersion Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.23.0" />
3535
<PackageVersion Include="Microsoft.AspNetCore.SignalR.Core" Version="1.1.0" />
3636
<PackageVersion Include="Microsoft.AspNetCore.SignalR.Protocols.MessagePack" Version="9.0.0" />
37-
<PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.53.1" />
38-
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.EventHubs" Version="6.5.2" />
37+
<PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.55.0" />
38+
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.EventHubs" Version="6.5.3" />
3939
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.ServiceBus" Version="5.17.0" />
4040
<PackageVersion Include="Microsoft.Bcl.AsyncInterfaces" Version="8.0.0" />
4141
<PackageVersion Include="Microsoft.CodeAnalysis.CSharp.Workspaces" Version="4.11.0" />
@@ -103,10 +103,10 @@
103103
<PackageVersion Include="Microsoft.Extensions.Options" Version="10.0.0"
104104
Condition="$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)', 'net10.0'))" />
105105
<PackageVersion Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
106-
<PackageVersion Include="MongoDB.Driver" Version="3.5.0" />
106+
<PackageVersion Include="MongoDB.Driver" Version="3.5.1" />
107107
<PackageVersion Include="Newtonsoft.Json" Version="13.0.4" />
108108
<PackageVersion Include="Newtonsoft.Json.Bson" Version="1.0.3" />
109-
<PackageVersion Include="NHibernate" Version="5.5.3" />
109+
<PackageVersion Include="NHibernate" Version="5.6.0" />
110110
<PackageVersion Include="Npgsql" Version="8.0.7" />
111111
<PackageVersion Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.0" />
112112
<PackageVersion Include="NUnit" Version="4.4.0" />
@@ -119,13 +119,13 @@
119119
<PackageVersion Include="OpenTelemetry.Exporter.Jaeger" Version="1.5.1" />
120120
<PackageVersion Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.9.0" />
121121
<PackageVersion Include="OpenTelemetry.Extensions.Hosting" Version="1.12.0" />
122-
<PackageVersion Include="Quartz" Version="3.15.0" />
123-
<PackageVersion Include="Quartz.Extensions.Hosting" Version="3.15.0" />
122+
<PackageVersion Include="Quartz" Version="3.15.1" />
123+
<PackageVersion Include="Quartz.Extensions.Hosting" Version="3.15.1" />
124124
<PackageVersion Include="QuikGraph" Version="2.5.0" />
125125
<PackageVersion Include="QuikGraph.Graphviz" Version="2.5.0" />
126-
<PackageVersion Include="RabbitMQ.Client" Version="7.1.2" />
126+
<PackageVersion Include="RabbitMQ.Client" Version="7.2.0" />
127127
<PackageVersion Include="SharpZipLib" Version="1.4.2" />
128-
<PackageVersion Include="StackExchange.Redis" Version="2.9.11" />
128+
<PackageVersion Include="StackExchange.Redis" Version="2.10.1" />
129129
<PackageVersion Include="System.Data.SqlClient" Version="4.9.0" />
130130
<PackageVersion Include="System.Data.SQLite" Version="1.0.119" />
131131
<PackageVersion Include="System.Diagnostics.DiagnosticSource" Version="8.0.1" Condition="!$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)', 'net9.0'))" />
@@ -152,4 +152,4 @@
152152
<GlobalPackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
153153
<GlobalPackageReference Include="Microsoft.SourceLink.GitHub" Version="8.0.0" />
154154
</ItemGroup>
155-
</Project>
155+
</Project>

‎src/Persistence/MassTransit.RedisIntegration/RedisIntegration/Saga/RedisDatabaseContext.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,8 @@ async Task<TSaga> Get(IObjectDeserializer deserializer, Guid correlationId)
113113

114114
Task Put(string instance, Guid correlationId)
115115
{
116-
return _database.StringSetAsync(_options.FormatSagaKey(correlationId), instance, _options.Expiry);
116+
return _database.StringSetAsync(_options.FormatSagaKey(correlationId), instance,
117+
_options.Expiry.HasValue ? new Expiration(_options.Expiry.Value) : Expiration.Default);
117118
}
118119

119120
Task Delete(Guid correlationId)

0 commit comments

Comments
 (0)