Skip to content

Commit 866c0e0

Browse files
committed
Add new API
1 parent 0fb90e6 commit 866c0e0

File tree

3 files changed

+18
-4
lines changed

3 files changed

+18
-4
lines changed

src/NServiceBus.NHibernate.TransactionalSession.Tests/ApprovalFiles/APIApprovals.Approve.approved.txt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ namespace NServiceBus.TransactionalSession
77
public static class NHibernateTransactionalSessionExtensions
88
{
99
public static NServiceBus.PersistenceExtensions<NServiceBus.NHibernatePersistence> EnableTransactionalSession(this NServiceBus.PersistenceExtensions<NServiceBus.NHibernatePersistence> persistenceExtensions) { }
10+
public static NServiceBus.PersistenceExtensions<NServiceBus.NHibernatePersistence> EnableTransactionalSession(this NServiceBus.PersistenceExtensions<NServiceBus.NHibernatePersistence> persistenceExtensions, NServiceBus.TransactionalSession.TransactionalSessionOptions transactionalSessionOptions) { }
1011
public static System.Threading.Tasks.Task Open(this NServiceBus.TransactionalSession.ITransactionalSession transactionalSession, System.Threading.CancellationToken cancellationToken = default) { }
1112
}
1213
}

src/NServiceBus.NHibernate.TransactionalSession/NHibernateTransactionalSessionExtensions.cs

Lines changed: 16 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
namespace NServiceBus.TransactionalSession
22
{
3+
using System;
34
using System.Threading;
45
using System.Threading.Tasks;
56
using Configuration.AdvancedExtensibility;
@@ -10,13 +11,25 @@
1011
/// </summary>
1112
public static class NHibernateTransactionalSessionExtensions
1213
{
13-
/// <summary>
1414
/// Enables transactional session for this endpoint.
1515
/// </summary>
1616
public static PersistenceExtensions<NHibernatePersistence> EnableTransactionalSession(
17-
this PersistenceExtensions<NHibernatePersistence> persistenceExtensions)
17+
this PersistenceExtensions<NHibernatePersistence> persistenceExtensions) =>
18+
EnableTransactionalSession(persistenceExtensions, new TransactionalSessionOptions());
19+
20+
/// <summary>
21+
/// Enables the transactional session for this endpoint using the specified TransactionalSessionOptions.
22+
/// </summary>
23+
public static PersistenceExtensions<NHibernatePersistence> EnableTransactionalSession(this PersistenceExtensions<NHibernatePersistence> persistenceExtensions,
24+
TransactionalSessionOptions transactionalSessionOptions)
1825
{
19-
persistenceExtensions.GetSettings().EnableFeatureByDefault(typeof(NHibernateTransactionalSession));
26+
ArgumentNullException.ThrowIfNull(persistenceExtensions);
27+
ArgumentNullException.ThrowIfNull(transactionalSessionOptions);
28+
29+
var settings = persistenceExtensions.GetSettings();
30+
31+
settings.Set(transactionalSessionOptions);
32+
settings.EnableFeatureByDefault<NHibernateTransactionalSession>();
2033

2134
return persistenceExtensions;
2235
}

src/NServiceBus.NHibernate.TransactionalSession/NServiceBus.NHibernate.TransactionalSession.csproj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
</ItemGroup>
1515

1616
<ItemGroup>
17-
<PackageReference Include="NServiceBus.TransactionalSession" Version="3.2.0" />
17+
<PackageReference Include="NServiceBus.TransactionalSession" Version="3.3.0-beta1" />
1818
<PackageReference Include="Particular.Packaging" Version="4.2.2" PrivateAssets="All" />
1919
</ItemGroup>
2020

0 commit comments

Comments
 (0)