Skip to content

Commit 16804c0

Browse files
Update NServiceBus Core to 10.0.0-alpha.5 (#1806)
* Update NServiceBus Core to 10.0.0-alpha.5 * Implement IAsyncDisposable * Cleanup * Async --------- Co-authored-by: dependencyupdates[bot] <218638057+dependencyupdates[bot]@users.noreply.github.com> Co-authored-by: Daniel Marbach <[email protected]>
1 parent 662dac1 commit 16804c0

File tree

12 files changed

+58
-39
lines changed

12 files changed

+58
-39
lines changed

src/MsSqlMicrosoftDataClientAcceptanceTests/MsSqlMicrosoftDataClientAcceptanceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
<ItemGroup>
1313
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1414
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
15-
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.4" />
15+
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.5" />
1616
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
1717
</ItemGroup>
1818

src/MsSqlMicrosoftDataClientSqlTransportAcceptanceTests/MsSqlMicrosoftDataClientSqlTransportAcceptanceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
<ItemGroup>
1414
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1515
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
16-
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.4" GeneratePathProperty="true" />
16+
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.5" GeneratePathProperty="true" />
1717
<PackageReference Include="NServiceBus.Transport.SqlServer" Version="9.0.0-alpha.2" />
1818
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
1919
</ItemGroup>

src/MySqlAcceptanceTests/MySqlAcceptanceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
<ItemGroup>
1212
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1313
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
14-
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.4" GeneratePathProperty="true" />
14+
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.5" GeneratePathProperty="true" />
1515
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
1616
</ItemGroup>
1717

src/OracleAcceptanceTests/OracleAcceptanceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
<ItemGroup>
1414
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1515
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
16-
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.4" GeneratePathProperty="true" />
16+
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.5" GeneratePathProperty="true" />
1717
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
1818
</ItemGroup>
1919

src/PostgreSqlAcceptanceTests/PostgreSqlAcceptanceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
<ItemGroup>
1212
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1313
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
14-
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.4" />
14+
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.5" />
1515
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
1616
</ItemGroup>
1717

src/PostgreSqlTransportAcceptanceTests/PostgreSqlTransportAcceptanceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
<ItemGroup>
1414
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1515
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
16-
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.4" GeneratePathProperty="true" />
16+
<PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.5" GeneratePathProperty="true" />
1717
<PackageReference Include="NServiceBus.Transport.PostgreSql" Version="9.0.0-alpha.2" />
1818
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
1919
</ItemGroup>

src/SqlPersistence.PersistenceTests/SqlPersistence.PersistenceTests.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
<ItemGroup>
1616
<PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
1717
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
18-
<PackageReference Include="NServiceBus.PersistenceTests.Sources" Version="10.0.0-alpha.4" GeneratePathProperty="true" />
18+
<PackageReference Include="NServiceBus.PersistenceTests.Sources" Version="10.0.0-alpha.5" GeneratePathProperty="true" />
1919
<PackageReference Include="NUnit3TestAdapter" Version="5.1.0" />
2020
</ItemGroup>
2121

src/SqlPersistence/Outbox/AdoNetSqlOutboxTransaction.cs

Lines changed: 25 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -5,20 +5,12 @@
55
using NServiceBus.Extensibility;
66
using NServiceBus.Outbox;
77

8-
class AdoNetSqlOutboxTransaction : ISqlOutboxTransaction
8+
sealed class AdoNetSqlOutboxTransaction(
9+
ConcurrencyControlStrategy concurrencyControlStrategy,
10+
IConnectionManager connectionManager,
11+
IsolationLevel isolationLevel)
12+
: ISqlOutboxTransaction
913
{
10-
IConnectionManager connectionManager;
11-
IsolationLevel isolationLevel;
12-
ConcurrencyControlStrategy concurrencyControlStrategy;
13-
14-
public AdoNetSqlOutboxTransaction(ConcurrencyControlStrategy concurrencyControlStrategy,
15-
IConnectionManager connectionManager, IsolationLevel isolationLevel)
16-
{
17-
this.connectionManager = connectionManager;
18-
this.isolationLevel = isolationLevel;
19-
this.concurrencyControlStrategy = concurrencyControlStrategy;
20-
}
21-
2214
public DbTransaction Transaction { get; private set; }
2315
public DbConnection Connection { get; private set; }
2416

@@ -31,7 +23,7 @@ public async Task Begin(ContextBag context, CancellationToken cancellationToken
3123
{
3224
var incomingMessage = context.GetIncomingMessage();
3325
Connection = await connectionManager.OpenConnection(incomingMessage, cancellationToken).ConfigureAwait(false);
34-
Transaction = Connection.BeginTransaction(isolationLevel);
26+
Transaction = await Connection.BeginTransactionAsync(isolationLevel, cancellationToken).ConfigureAwait(false);
3527
await concurrencyControlStrategy.Begin(incomingMessage.MessageId, Connection, Transaction, cancellationToken).ConfigureAwait(false);
3628
}
3729

@@ -42,6 +34,25 @@ public void Dispose()
4234
{
4335
Transaction?.Dispose();
4436
Connection?.Dispose();
37+
38+
Transaction = null;
39+
Connection = null;
40+
}
41+
42+
public async ValueTask DisposeAsync()
43+
{
44+
if (Transaction is not null)
45+
{
46+
await Transaction.DisposeAsync().ConfigureAwait(false);
47+
}
48+
49+
if (Connection is not null)
50+
{
51+
await Connection.DisposeAsync().ConfigureAwait(false);
52+
}
53+
54+
Transaction = null;
55+
Connection = null;
4556
}
4657

4758
public Task Commit(CancellationToken cancellationToken = default)

src/SqlPersistence/Outbox/TransactionScopeSqlOutboxTransaction.cs

Lines changed: 23 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -6,23 +6,15 @@
66
using NServiceBus.Extensibility;
77
using NServiceBus.Outbox;
88

9-
class TransactionScopeSqlOutboxTransaction : ISqlOutboxTransaction
9+
sealed class TransactionScopeSqlOutboxTransaction(
10+
ConcurrencyControlStrategy concurrencyControlStrategy,
11+
IConnectionManager connectionManager,
12+
IsolationLevel isolationLevel,
13+
TimeSpan transactionTimeout)
14+
: ISqlOutboxTransaction
1015
{
11-
IConnectionManager connectionManager;
12-
IsolationLevel isolationLevel;
13-
ConcurrencyControlStrategy concurrencyControlStrategy;
1416
TransactionScope transactionScope;
1517
Transaction ambientTransaction;
16-
TimeSpan transactionTimeout;
17-
18-
public TransactionScopeSqlOutboxTransaction(ConcurrencyControlStrategy concurrencyControlStrategy,
19-
IConnectionManager connectionManager, IsolationLevel isolationLevel, TimeSpan transactionTimeout)
20-
{
21-
this.connectionManager = connectionManager;
22-
this.isolationLevel = isolationLevel;
23-
this.concurrencyControlStrategy = concurrencyControlStrategy;
24-
this.transactionTimeout = transactionTimeout;
25-
}
2618

2719
public DbTransaction Transaction => null;
2820
public DbConnection Connection { get; private set; }
@@ -55,14 +47,30 @@ public void Dispose()
5547
{
5648
transactionScope?.Dispose();
5749
Connection?.Dispose();
50+
51+
transactionScope = null;
52+
ambientTransaction = null;
53+
Connection = null;
54+
}
55+
56+
public async ValueTask DisposeAsync()
57+
{
58+
transactionScope?.Dispose();
59+
60+
if (Connection is not null)
61+
{
62+
await Connection.DisposeAsync().ConfigureAwait(false);
63+
}
64+
5865
transactionScope = null;
5966
ambientTransaction = null;
67+
Connection = null;
6068
}
6169

6270
public Task Commit(CancellationToken cancellationToken = default)
6371
{
6472
transactionScope?.Complete();
65-
// we need to dispose it after completion in order to execute the transaction after marking it as completed
73+
// we need to dispose it after completion to execute the transaction after marking it as completed
6674
transactionScope?.Dispose();
6775
return Task.CompletedTask;
6876
}

src/SqlPersistence/SqlPersistence.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414

1515
<ItemGroup>
1616
<PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
17-
<PackageReference Include="NServiceBus" Version="10.0.0-alpha.4" />
17+
<PackageReference Include="NServiceBus" Version="10.0.0-alpha.5" />
1818
</ItemGroup>
1919

2020
<ItemGroup>

0 commit comments

Comments
 (0)