Skip to content

Commit a8c9b7b

Browse files
StuartFergusonStuartFerguson
committed
Fix issues with subscriptions
1 parent 8503aca commit a8c9b7b

11 files changed

Lines changed: 17 additions & 17 deletions

File tree

‎TransactionProcessor.BusinessLogic/TransactionProcessor.BusinessLogic.csproj‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,9 @@
77
<ItemGroup>
88
<PackageReference Include="EstateManagement.Client" Version="1.1.1" />
99
<PackageReference Include="MessagingService.Client" Version="1.1.0" />
10-
<PackageReference Include="SecurityService.Client" Version="1.1.0" />
11-
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.2" />
12-
<PackageReference Include="Shared.EventStore" Version="1.3.2" />
10+
<PackageReference Include="SecurityService.Client" Version="1.1.1-build9" />
11+
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.3" />
12+
<PackageReference Include="Shared.EventStore" Version="1.3.3" />
1313
<PackageReference Include="MediatR" Version="10.0.1" />
1414
<PackageReference Include="System.IO.Abstractions" Version="17.0.15" />
1515
<PackageReference Include="VoucherManagement.Client" Version="1.1.0" />

‎TransactionProcessor.Client/TransactionProcessor.Client.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
</PropertyGroup>
77

88
<ItemGroup>
9-
<PackageReference Include="ClientProxyBase" Version="1.3.2" />
9+
<PackageReference Include="ClientProxyBase" Version="1.3.3" />
1010
</ItemGroup>
1111

1212
<ItemGroup>

‎TransactionProcessor.IntegrationTests/TransactionProcessor.IntegrationTests.csproj‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
</PropertyGroup>
88

99
<ItemGroup>
10-
<PackageReference Include="ClientProxyBase" Version="1.3.2" />
10+
<PackageReference Include="ClientProxyBase" Version="1.3.3" />
1111
<PackageReference Include="Ductus.FluentDocker" Version="2.10.48" />
1212
<PackageReference Include="EstateManagement.Client" Version="1.1.1" />
1313
<PackageReference Include="EstateReporting.Database" Version="1.1.2" />
@@ -17,7 +17,7 @@
1717
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="6.0.5" />
1818
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.2.0" />
1919
<PackageReference Include="SecurityService.Client" Version="1.1.1-build9" />
20-
<PackageReference Include="Shared.IntegrationTesting" Version="1.3.2" />
20+
<PackageReference Include="Shared.IntegrationTesting" Version="1.3.3" />
2121
<PackageReference Include="Shouldly" Version="4.0.3" />
2222
<PackageReference Include="SpecFlow" Version="3.9.74" />
2323
<PackageReference Include="SpecFlow.Tools.MsBuild.Generation" Version="3.9.74" />

‎TransactionProcessor.Reconciliation.DomainEvents/TransactionProcessor.Reconciliation.DomainEvents.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,6 @@
55
</PropertyGroup>
66

77
<ItemGroup>
8-
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.2" />
8+
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.3" />
99
</ItemGroup>
1010
</Project>

‎TransactionProcessor.ReconciliationAggregate/TransactionProcessor.ReconciliationAggregate.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
</PropertyGroup>
66

77
<ItemGroup>
8-
<PackageReference Include="Shared.EventStore" Version="1.3.2" />
8+
<PackageReference Include="Shared.EventStore" Version="1.3.3" />
99
</ItemGroup>
1010

1111
<ItemGroup>

‎TransactionProcessor.Settlement.DomainEvents/TransactionProcessor.Settlement.DomainEvents.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
</PropertyGroup>
66

77
<ItemGroup>
8-
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.2" />
8+
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.3" />
99
</ItemGroup>
1010

1111
</Project>

‎TransactionProcessor.SettlementAggregates/TransactionProcessor.SettlementAggregates.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
</PropertyGroup>
66

77
<ItemGroup>
8-
<PackageReference Include="Shared.EventStore" Version="1.3.2" />
8+
<PackageReference Include="Shared.EventStore" Version="1.3.3" />
99
</ItemGroup>
1010

1111
<ItemGroup>

‎TransactionProcessor.Transaction.DomainEvents/TransactionProcessor.Transaction.DomainEvents.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
</PropertyGroup>
66

77
<ItemGroup>
8-
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.2" />
8+
<PackageReference Include="Shared.DomainDrivenDesign" Version="1.3.3" />
99
</ItemGroup>
1010

1111
</Project>

‎TransactionProcessor.TransactionAgrgegate/TransactionProcessor.TransactionAggregate.csproj‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
</PropertyGroup>
66

77
<ItemGroup>
8-
<PackageReference Include="Shared.EventStore" Version="1.3.2" />
8+
<PackageReference Include="Shared.EventStore" Version="1.3.3" />
99
</ItemGroup>
1010

1111
<ItemGroup>

‎TransactionProcessor/Extensions.cs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,13 +56,13 @@ public static void PreWarm(this IApplicationBuilder applicationBuilder)
5656
ISubscriptionRepository subscriptionRepository = SubscriptionRepository.Create(eventStoreConnectionString, cacheDuration);
5757

5858
((SubscriptionRepository)subscriptionRepository).Trace += (sender, s) => Extensions.log(TraceEventType.Information, "REPOSITORY", s);
59-
59+
6060
// init our SubscriptionRepository
6161
subscriptionRepository.PreWarm(CancellationToken.None).Wait();
6262

6363
var eventHandlerResolver = Startup.ServiceProvider.GetService<IDomainEventHandlerResolver>();
6464

65-
SubscriptionWorker concurrentSubscriptions = SubscriptionWorker.CreateConcurrentSubscriptionWorker(eventStoreConnectionString, eventHandlerResolver, subscriptionRepository, inflightMessages, persistentSubscriptionPollingInSeconds);
65+
SubscriptionWorker concurrentSubscriptions = SubscriptionWorker.CreateConcurrentSubscriptionWorker(Startup.EventStoreClientSettings, eventHandlerResolver, subscriptionRepository, inflightMessages, persistentSubscriptionPollingInSeconds);
6666

6767
concurrentSubscriptions.Trace += (_, args) => Extensions.concurrentLog(TraceEventType.Information, args.Message);
6868
concurrentSubscriptions.Warning += (_, args) => Extensions.concurrentLog(TraceEventType.Warning, args.Message);
@@ -75,7 +75,7 @@ public static void PreWarm(this IApplicationBuilder applicationBuilder)
7575

7676
if (!String.IsNullOrEmpty(filter))
7777
{
78-
//NOTE: Not overly happy with this design, but
78+
//NOTE: Not overly happy with this design, but;
7979
//the idea is if we supply a filter, this overrides ignore
8080
concurrentSubscriptions = concurrentSubscriptions.FilterSubscriptions(filter)
8181
.IgnoreSubscriptions(null);

0 commit comments

Comments
 (0)