Skip to content

Commit 046d325

Browse files
Update Snippets for NSB10 - Callbacks/Callbacks.Testing (#7728)
* Add NSB10 snippets for NServiceBus.Callbacks * Add NSB10 snippets for NServiceBus.Callbacks.Testing * Add prerelease.txt
1 parent 5dffc0c commit 046d325

33 files changed

+540
-0
lines changed

Snippets/Callbacks/Callbacks.sln

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Callbacks_4", "Callbacks_4\
88
EndProject
99
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Callbacks_5", "Callbacks_5\Callbacks_5.csproj", "{E246155A-0E68-4D25-B340-9E844EECC9D1}"
1010
EndProject
11+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Callbacks_6", "Callbacks_6\Callbacks_6.csproj", "{AF7161F9-E5FD-A4F8-EC16-98A41E323B7D}"
12+
EndProject
1113
Global
1214
GlobalSection(SolutionConfigurationPlatforms) = preSolution
1315
Debug|Any CPU = Debug|Any CPU
@@ -26,6 +28,10 @@ Global
2628
{E246155A-0E68-4D25-B340-9E844EECC9D1}.Debug|Any CPU.Build.0 = Debug|Any CPU
2729
{E246155A-0E68-4D25-B340-9E844EECC9D1}.Release|Any CPU.ActiveCfg = Release|Any CPU
2830
{E246155A-0E68-4D25-B340-9E844EECC9D1}.Release|Any CPU.Build.0 = Release|Any CPU
31+
{AF7161F9-E5FD-A4F8-EC16-98A41E323B7D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
32+
{AF7161F9-E5FD-A4F8-EC16-98A41E323B7D}.Debug|Any CPU.Build.0 = Debug|Any CPU
33+
{AF7161F9-E5FD-A4F8-EC16-98A41E323B7D}.Release|Any CPU.ActiveCfg = Release|Any CPU
34+
{AF7161F9-E5FD-A4F8-EC16-98A41E323B7D}.Release|Any CPU.Build.0 = Release|Any CPU
2935
EndGlobalSection
3036
GlobalSection(SolutionProperties) = preSolution
3137
HideSolutionNode = FALSE
Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
<PropertyGroup>
3+
<TargetFramework>net10.0</TargetFramework>
4+
</PropertyGroup>
5+
<ItemGroup>
6+
<PackageReference Include="NServiceBus.Callbacks" Version="6.0.0-alpha.2" />
7+
</ItemGroup>
8+
</Project>
Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
namespace Callbacks.Cancellation
2+
{
3+
using NServiceBus;
4+
5+
public class Message :
6+
IMessage
7+
{
8+
}
9+
}
Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
namespace Callbacks.Cancellation
2+
{
3+
using System;
4+
using System.Threading;
5+
using System.Threading.Tasks;
6+
using NServiceBus;
7+
8+
class Usage
9+
{
10+
async Task Simple(IEndpointInstance endpoint)
11+
{
12+
#region CancelCallback
13+
14+
var cancellationTokenSource = new CancellationTokenSource();
15+
cancellationTokenSource.CancelAfter(TimeSpan.FromSeconds(5));
16+
var message = new Message();
17+
try
18+
{
19+
var response = await endpoint.Request<int>(message, cancellationTokenSource.Token);
20+
}
21+
catch (OperationCanceledException)
22+
{
23+
// Exception that is raised when the CancellationTokenSource is canceled
24+
}
25+
26+
#endregion
27+
}
28+
29+
}
30+
}
Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
#pragma warning disable 1998
2+
namespace Callbacks.Handlers
3+
{
4+
using System.Threading.Tasks;
5+
using NServiceBus;
6+
7+
#region EmptyHandler
8+
9+
public class MyMessageHandler :
10+
IHandleMessages<MyMessage>
11+
{
12+
public async Task Handle(MyMessage message, IMessageHandlerContext context)
13+
{
14+
// do something in the client process
15+
}
16+
}
17+
18+
#endregion
19+
20+
public class MyMessage
21+
{
22+
}
23+
}
Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
namespace Callbacks.Enable
2+
{
3+
using NServiceBus;
4+
5+
class Usage
6+
{
7+
void Simple(EndpointConfiguration endpointConfiguration)
8+
{
9+
#region EnableCallbacks-Default
10+
11+
endpointConfiguration.EnableCallbacks();
12+
13+
#endregion
14+
15+
#region EnableCallbacks-NoRequests
16+
17+
endpointConfiguration.EnableCallbacks(makesRequests: false);
18+
19+
#endregion
20+
}
21+
}
22+
}
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
namespace Callbacks.Enum
2+
{
3+
using System.Threading.Tasks;
4+
using NServiceBus;
5+
6+
#region EnumCallbackResponse
7+
8+
public class Handler :
9+
IHandleMessages<Message>
10+
{
11+
public Task Handle(Message message, IMessageHandlerContext context)
12+
{
13+
return context.Reply(Status.OK);
14+
}
15+
}
16+
17+
#endregion
18+
}
Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
namespace Callbacks.Enum
2+
{
3+
using NServiceBus;
4+
5+
public class Message :
6+
IMessage
7+
{
8+
}
9+
}
Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
namespace Callbacks.Enum
2+
{
3+
public enum Status
4+
{
5+
OK,
6+
Error
7+
}
8+
}
Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
namespace Callbacks.Enum
2+
{
3+
using System.Threading.Tasks;
4+
using NServiceBus;
5+
using NServiceBus.Logging;
6+
7+
class Usage
8+
{
9+
async Task Simple(IEndpointInstance endpoint, ILog log)
10+
{
11+
#region EnumCallback
12+
13+
var message = new Message();
14+
var response = await endpoint.Request<Status>(message);
15+
log.Info($"Callback received with response:{response}");
16+
17+
#endregion
18+
}
19+
}
20+
}

0 commit comments

Comments
 (0)