Dramatic refactor of SqlReceiver and its dependencies.

Author: ascott18

demo/DemoServer/ChatHub.cs

@@ -14,11 +14,11 @@ public ChatHubA(ILogger<ChatHubA> logger)
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
         }
 
-        private string groupId = Guid.Empty.ToString();
+        private readonly string groupId = Guid.Empty.ToString();
 
         public async Task SendMessage(string name, string message)
         {
-            _logger.LogInformation($"{nameof(SendMessage)} called. ConnectionId:{Context.ConnectionId}, Name:{name}, Message:{message}");
+          //  _logger.LogInformation($"{nameof(SendMessage)} called. ConnectionId:{Context.ConnectionId}, Name:{name}, Message:{message}");
             await Clients.Group(groupId).SendAsync("BroadcastMessage", name, message);
         }
 
@@ -38,6 +38,7 @@ public override async Task OnDisconnectedAsync(Exception exception)
             await Groups.RemoveFromGroupAsync(Context.ConnectionId, Guid.Empty.ToString());
         }
     }
+
     public class ChatHubB : Hub
     {
         private readonly ILogger<ChatHubB> _logger;
@@ -47,11 +48,11 @@ public ChatHubB(ILogger<ChatHubB> logger)
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
         }
 
-        private string groupId = Guid.Empty.ToString();
+        private readonly string groupId = Guid.Empty.ToString();
 
         public async Task SendMessage(string name, string message)
         {
-            _logger.LogInformation($"{nameof(SendMessage)} called. ConnectionId:{Context.ConnectionId}, Name:{name}, Message:{message}");
+          //  _logger.LogInformation($"{nameof(SendMessage)} called. ConnectionId:{Context.ConnectionId}, Name:{name}, Message:{message}");
             await Clients.Group(groupId).SendAsync("BroadcastMessage", name, message);
         }
 

demo/DemoServer/Program.cs

@@ -10,7 +10,7 @@
 
 namespace DemoServer
 {
-    public class Program
+    public static class Program
     {
         public static void Main(string[] args)
         {

demo/DemoServer/Startup.cs

@@ -30,8 +30,8 @@ public void ConfigureServices(IServiceCollection services)
                 {
                     o.ConnectionString = Configuration.GetConnectionString("Default");
                     o.AutoEnableServiceBroker = true;
-                    o.TableCount = 1;
-                    o.SchemaName = "Signalrcore";
+                    o.TableCount = 50;
+                    //o.SchemaName = "Signalrcore";
                 });
         }
 
@@ -60,7 +60,7 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
             {
                 endpoints.MapRazorPages();
                 endpoints.MapHub<ChatHubA>("/chatHubA");
-                //endpoints.MapHub<ChatHubB>("/chatHubB");
+                endpoints.MapHub<ChatHubB>("/chatHubB");
             });
         }
     }

demo/DemoServer/appsettings.json

@@ -3,7 +3,6 @@
     "LogLevel": {
       "Default": "Information",
       "Microsoft": "Warning",
-      //"IntelliTect.AspNetCore.SignalR": "Information",
       "IntelliTect.AspNetCore.SignalR": "Debug",
       "Microsoft.Hosting.Lifetime": "Information"
     }

…qlServer/Internal/Messages/AckMessage.cs …Internal/Messages/SqlServerAckMessage.cssrc/IntelliTect.AspNetCore.SignalR.SqlServer/Internal/Messages/AckMessage.cs renamed to src/IntelliTect.AspNetCore.SignalR.SqlServer/Internal/Messages/SqlServerAckMessage.cs src/IntelliTect.AspNetCore.SignalR.SqlServer/Internal/Messages/AckMessage.cs renamed to src/IntelliTect.AspNetCore.SignalR.SqlServer/Internal/Messages/SqlServerAckMessage.cs

@@ -7,13 +7,13 @@
 
 namespace IntelliTect.AspNetCore.SignalR.SqlServer.Internal.Messages
 {
-    internal readonly struct AckMessage
+    internal readonly struct SqlServerAckMessage
     {
         public int Id { get; }
 
         public string ServerName { get; }
 
-        public AckMessage(int id, string serverName)
+        public SqlServerAckMessage(int id, string serverName)
         {
             Id = id;
             ServerName = serverName;