ServiceControl EventsSubscription sample (#7478)

* fixing existing samples

* core 10 version of the sample

* Revert "core 10 version of the sample"

This reverts commit 15849fa.

* Clean up samples

---------

Co-authored-by: Brandon Ording <[email protected]>

Author: tmasternak

samples/servicecontrol/events-subscription/ServiceControlContracts_3/NServiceBusEndpoint/Program.cs

@@ -13,6 +13,11 @@ static async Task Main()
         endpointConfiguration.EnableInstallers();
         endpointConfiguration.SendFailedMessagesTo("error");
 
+        endpointConfiguration.SendHeartbeatTo(
+            serviceControlQueue: "Particular.ServiceControl",
+            frequency: TimeSpan.FromSeconds(10),
+            timeToLive: TimeSpan.FromSeconds(30));
+
         #region DisableRetries
 
         var recoverability = endpointConfiguration.Recoverability();
@@ -31,9 +36,11 @@ static async Task Main()
         #endregion
 
         var endpointInstance = await Endpoint.Start(endpointConfiguration);
-        Console.WriteLine("Press 'Enter' to send a new message. Press any other key to finish.");
+
         while (true)
         {
+            Console.WriteLine("Press 'Enter' to send a new message. Press any other key to finish.");
+
             var key = Console.ReadKey();
 
             if (key.Key != ConsoleKey.Enter)
@@ -47,10 +54,10 @@ static async Task Main()
             {
                 Id = guid
             };
+
             await endpointInstance.Send("NServiceBusEndpoint", simpleMessage);
-            Console.WriteLine($"Sent a new message with Id = {guid}.");
 
-            Console.WriteLine("Press 'Enter' to send a new message. Press any other key to finish.");
+            Console.WriteLine($"Sent a new message with Id = {guid}.");
         }
         await endpointInstance.Stop();
     }

samples/servicecontrol/events-subscription/ServiceControlContracts_3/PlatformLauncher/PlatformLauncher.csproj

@@ -3,6 +3,7 @@
   <PropertyGroup>
     <OutputType>Exe</OutputType>
     <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>true</ImplicitUsings>
     <LangVersion>12.0</LangVersion>
   </PropertyGroup>
 

samples/servicecontrol/events-subscription/ServiceControlContracts_3/PlatformLauncher/Program.cs

@@ -1,14 +1,2 @@
-namespace PlatformLauncher
-{
-    using System;
-    using System.Threading.Tasks;
-
-    class Program
-    {
-        static async Task Main(string[] args)
-        {
-            Console.Title = "PlatformLauncher";
-            await Particular.PlatformLauncher.Launch();
-        }
-    }
-}
+Console.Title = "PlatformLauncher";
+await Particular.PlatformLauncher.Launch();

samples/servicecontrol/events-subscription/ServiceControlContracts_4/EndpointsMonitor/CustomEventsHandler.cs

@@ -1,8 +1,4 @@
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading.Tasks;
-using Microsoft.Extensions.Logging;
-using NServiceBus;
+using Microsoft.Extensions.Logging;
 using ServiceControl.Contracts;
 
 #region ServiceControlEventsHandlers

samples/servicecontrol/events-subscription/ServiceControlContracts_4/EndpointsMonitor/EndpointsMonitor.csproj

@@ -1,15 +1,16 @@
 <Project Sdk="Microsoft.NET.Sdk">
+
   <PropertyGroup>
     <TargetFrameworks>net9.0;net8.0</TargetFrameworks>
     <OutputType>Exe</OutputType>
+    <ImplicitUsings>true</ImplicitUsings>
     <LangVersion>12.0</LangVersion>
   </PropertyGroup>
+
   <ItemGroup>
-    <PackageReference Include="Newtonsoft.Json" Version="13.*" />
     <PackageReference Include="NServiceBus" Version="8.*" />
-    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="2.0.1" />
-    <PackageReference Include="NServiceBus.Persistence.NonDurable" Version="1.*" />
-    <PackageReference Include="NServiceBus.Newtonsoft.Json" Version="3.*" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="2.*" />
     <PackageReference Include="ServiceControl.Contracts" Version="4.*" />
   </ItemGroup>
+
 </Project>

samples/servicecontrol/events-subscription/ServiceControlContracts_4/EndpointsMonitor/Program.cs

@@ -1,45 +1,34 @@
 using Microsoft.Extensions.Hosting;
-using NServiceBus;
-using System;
-using System.Threading.Tasks;
 
-class Program
+Console.Title = "EndpointsMonitor";
+
+var builder = Host.CreateDefaultBuilder(args);
+
+builder.UseNServiceBus(x =>
 {
-    public static async Task Main(string[] args)
-    {
-        await CreateHostBuilder(args).Build().RunAsync();
-    }
-
-    public static IHostBuilder CreateHostBuilder(string[] args) =>
-     Host.CreateDefaultBuilder(args)
-         .ConfigureServices((hostContext, services) =>
-         {
-             Console.Title = "EndpointsMonitor";
-
-         }).UseNServiceBus(x =>
-         {
-             var endpointConfiguration = new EndpointConfiguration("EndpointsMonitor");
-             endpointConfiguration.UseSerialization<NewtonsoftJsonSerializer>();
-             endpointConfiguration.EnableInstallers();
-             endpointConfiguration.UsePersistence<NonDurablePersistence>();
-
-             #region ServiceControlEventsMonitorCustomErrorQueue
-             endpointConfiguration.SendFailedMessagesTo("error-monitoring");
-             #endregion
-
-             var transport = endpointConfiguration.UseTransport<LearningTransport>();
-
-             var conventions = endpointConfiguration.Conventions();
-             conventions.DefiningEventsAs(
-                 type =>
-                 {
-                     return typeof(IEvent).IsAssignableFrom(type) ||
-                            // include ServiceControl events
-                            type.Namespace != null &&
-                            type.Namespace.StartsWith("ServiceControl.Contracts");
-                 });
-
-             return endpointConfiguration;
-         });
-
-}
+    var endpointConfiguration = new EndpointConfiguration("EndpointsMonitor");
+    endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+    endpointConfiguration.EnableInstallers();
+
+    #region ServiceControlEventsMonitorCustomErrorQueue
+    endpointConfiguration.SendFailedMessagesTo("error-monitoring");
+    #endregion
+
+    var transport = endpointConfiguration.UseTransport<LearningTransport>();
+
+    var conventions = endpointConfiguration.Conventions();
+    conventions.DefiningEventsAs(
+        type =>
+        {
+            return typeof(IEvent).IsAssignableFrom(type) ||
+                   // include ServiceControl events
+                   type.Namespace != null &&
+                   type.Namespace.StartsWith("ServiceControl.Contracts");
+        });
+
+    return endpointConfiguration;
+});
+
+var host = builder.Build();
+
+await host.RunAsync();

samples/servicecontrol/events-subscription/ServiceControlContracts_4/NServiceBusEndpoint/InputLoopService.cs

@@ -1,14 +1,16 @@
 <Project Sdk="Microsoft.NET.Sdk">
+
   <PropertyGroup>
     <TargetFrameworks>net9.0;net8.0</TargetFrameworks>
     <OutputType>Exe</OutputType>
+    <ImplicitUsings>true</ImplicitUsings>
     <LangVersion>12.0</LangVersion>
   </PropertyGroup>
+
   <ItemGroup>
-    <PackageReference Include="Newtonsoft.Json" Version="13.*" />
     <PackageReference Include="NServiceBus" Version="8.*" />
-    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="2.0.1" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="2.*" />
     <PackageReference Include="NServiceBus.Heartbeat" Version="4.*" />
-    <PackageReference Include="NServiceBus.Newtonsoft.Json" Version="3.*" />
   </ItemGroup>
+
 </Project>

samples/servicecontrol/events-subscription/ServiceControlContracts_4/NServiceBusEndpoint/NServiceBusEndpoint.csproj

@@ -1,49 +1,68 @@
-using System;
-using System.Threading.Tasks;
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
-using NServiceBus;
 
-class Program
+Console.Title = "NServiceBusEndpoint";
+
+var host = Host.CreateDefaultBuilder(args)
+    .UseNServiceBus(x =>
+    {
+        var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpoint");
+        endpointConfiguration.UseTransport<LearningTransport>();
+        endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+        endpointConfiguration.EnableInstallers();
+        endpointConfiguration.SendFailedMessagesTo("error");
+
+        endpointConfiguration.SendHeartbeatTo(
+            serviceControlQueue: "Particular.ServiceControl",
+            frequency: TimeSpan.FromSeconds(10),
+            timeToLive: TimeSpan.FromSeconds(30));
+
+        #region DisableRetries
+
+        var recoverability = endpointConfiguration.Recoverability();
+
+        recoverability.Delayed(retriesSettings =>
+        {
+            retriesSettings.NumberOfRetries(0);
+        });
+
+        recoverability.Immediate(retriesSettings =>
+        {
+            retriesSettings.NumberOfRetries(0);
+        });
+
+        #endregion
+
+        return endpointConfiguration;
+    })
+    .Build();
+
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+while (true)
 {
-    public static async Task Main(string[] args)
+    Console.WriteLine("Press 'Enter' to send a new message. Press any other key to finish.");
+
+    var key = Console.ReadKey();
+
+    if (key.Key != ConsoleKey.Enter)
     {
-        await CreateHostBuilder(args).Build().RunAsync();
+        break;
     }
 
-    public static IHostBuilder CreateHostBuilder(string[] args) =>
-     Host.CreateDefaultBuilder(args)
-       .UseNServiceBus(x =>
-         {           
-             var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpoint");
-             endpointConfiguration.UseTransport<LearningTransport>();
-             endpointConfiguration.UseSerialization<NewtonsoftJsonSerializer>();
-             endpointConfiguration.EnableInstallers();
-             endpointConfiguration.SendFailedMessagesTo("error");
-
-             #region DisableRetries
-
-             var recoverability = endpointConfiguration.Recoverability();
-
-             recoverability.Delayed(
-                 customizations: retriesSettings =>
-                 {
-                     retriesSettings.NumberOfRetries(0);
-                 });
-             recoverability.Immediate(
-                 customizations: retriesSettings =>
-                 {
-                     retriesSettings.NumberOfRetries(0);
-                 });
-
-             #endregion
-
-             return endpointConfiguration;
-         }).ConfigureServices((hostContext, services) =>
-         {
-             Console.Title = "NServiceBusEndpoint";
-             services.AddHostedService<InputLoopService>();
-
-         });
-
-}
+    var guid = Guid.NewGuid();
+
+    var simpleMessage = new SimpleMessage
+    {
+        Id = guid
+    };
+
+    await messageSession.Send("NServiceBusEndpoint", simpleMessage);
+
+    Console.WriteLine($"Sent a new message with Id = {guid}.");
+}
+
+await host.StopAsync();

samples/servicecontrol/events-subscription/ServiceControlContracts_4/NServiceBusEndpoint/Program.cs

@@ -1,7 +1,4 @@
-using System;
-using NServiceBus;
-
-public class SimpleMessage :
+public class SimpleMessage :
     IMessage
 {
     public Guid Id { get; set; }