Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using EndpointTemplates;
using Infrastructure.Settings;
Expand Down Expand Up @@ -104,7 +103,8 @@ public Task Handle(MessageReplyBySaga message, IMessageHandlerContext context)
{
Context.SagaId = message.SagaId;
}
Context.Done1();

Context.Replied = true;
return Task.FromResult(0);
}
}
Expand All @@ -119,7 +119,8 @@ public Task Handle(MessagePublishedBySaga message, IMessageHandlerContext contex
{
Context.SagaId = message.SagaId;
}
Context.Done2();

Context.Published = true;
return Task.FromResult(0);
}
}
Expand All @@ -134,7 +135,8 @@ public Task Handle(MessageReplyToOriginatorBySaga message, IMessageHandlerContex
{
Context.SagaId = message.SagaId;
}
Context.Done3();

Context.RepliedToOriginator = true;
return Task.FromResult(0);
}
}
Expand All @@ -149,7 +151,8 @@ public Task Handle(MessageSentBySaga message, IMessageHandlerContext context)
{
Context.SagaId = message.SagaId;
}
Context.Done4();

Context.Sent = true;
return Task.FromResult(0);
}
}
Expand Down Expand Up @@ -182,29 +185,12 @@ public class MessageReplyToOriginatorBySaga : IMessage

public class MyContext : ScenarioContext
{
long steps;

public void Done1()
{
Interlocked.Increment(ref steps);
}

public void Done2()
{
Interlocked.Increment(ref steps);
}

public void Done3()
{
Interlocked.Increment(ref steps);
}

public void Done4()
{
Interlocked.Increment(ref steps);
}
public bool Sent { get; set; }
public bool Replied { get; set; }
public bool RepliedToOriginator { get; set; }
public bool Published { get; set; }

public bool Done => Interlocked.Read(ref steps) >= 4;
public bool Done => Sent && Replied && RepliedToOriginator && Published;
public Guid? SagaId { get; set; }
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="NServiceBus" Version="7.1.5" />
<PackageReference Include="NServiceBus" Version="7.1.6" />
</ItemGroup>

</Project>
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="NServiceBus" Version="7.1.5" />
<PackageReference Include="NServiceBus" Version="7.1.6" />
</ItemGroup>

<ItemGroup>
Expand Down
2 changes: 1 addition & 1 deletion src/ServiceControl/ServiceControl.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
<PackageReference Include="Nancy.Bootstrappers.Autofac" Version="1.4.1" />
<PackageReference Include="Nancy.Owin" Version="1.4.1" />
<PackageReference Include="RavenDB.Database" Version="3.5.7" />
<PackageReference Include="NServiceBus" Version="7.1.5" />
<PackageReference Include="NServiceBus" Version="7.1.6" />
<PackageReference Include="NServiceBus.Autofac" Version="7.0.0" />
<PackageReference Include="NServiceBus.CustomChecks" Version="3.0.0" />
<PackageReference Include="NServiceBus.Newtonsoft.Json" Version="2.1.0" />
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
</PropertyGroup>

<ItemGroup>
<ProjectReference Include="..\ServiceControl.Transports.Learning\ServiceControl.Transports.Learning.csproj" />
<ProjectReference Include="..\ServiceControl.Transports.SQS\ServiceControl.Transports.SQS.csproj" />
<ProjectReference Include="..\ServiceControl\ServiceControl.csproj" />
<ProjectReference Include="..\ServiceControl.Transports.ASB\ServiceControl.Transports.ASB.csproj" />
Expand All @@ -16,7 +17,7 @@
</ItemGroup>

<ItemGroup>
<PackageReference Include="Packaging.ServiceControl.Monitoring" Version="2.0.2" PrivateAssets="All" />
<PackageReference Include="Packaging.ServiceControl.Monitoring" Version="2.0.3" PrivateAssets="All" />
</ItemGroup>

<UsingTask AssemblyFile="..\..\buildsupport\DeploymentZipTask.Dll" TaskName="DeploymentZipTask.AddToZip" />
Expand Down