Addressing some routing logic bugs in the fluent interface. Closes GH…

…-1099

src/Testing/CoreTests/Runtime/Routing/routing_precedence.cs → src/Testing/CoreTests/Runtime/Routing/routing_rules.cs

@@ -1,6 +1,8 @@
 using System.Diagnostics;
+using JasperFx.Core.Reflection;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
+using Module2;
 using Wolverine.ComplianceTests;
 using Wolverine.Attributes;
 using Wolverine.Configuration;
@@ -13,7 +15,7 @@
 
 namespace CoreTests.Runtime.Routing;
 
-public class routing_precedence
+public class routing_rules
 {
     [Fact]
     public async Task local_routing_is_applied_automatically()
@@ -206,6 +208,25 @@ public async Task use_no_handler_if_no_handler_and_no_subscriber()
         collection.FindInvoker(typeof(RedMessage))
             .ShouldBeOfType<NoHandlerExecutor>();
     }
+
+    // This one is for https://github.com/JasperFx/wolverine/issues/1099
+    [Fact]
+    public async Task route_with_fluent_interface()
+    {
+        var port = PortFinder.GetAvailablePort();
+        using var host = await Host.CreateDefaultBuilder()
+            .UseWolverine(opts =>
+            {
+                //opts.Discovery.IncludeAssembly(typeof(Module2Message1).Assembly);
+                opts.Publish().MessagesFromAssembly(typeof(Module2Message1).Assembly).ToPort(port);
+
+            }).StartAsync();
+
+        var bus = host.MessageBus();
+        var envelopes = bus.PreviewSubscriptions(new Module2Message1());
+
+        envelopes.Single().Destination.ShouldBe(new Uri("tcp://localhost:" + port));
+    }
 }
 
 public class ColorsMessageHandler

src/Wolverine/Configuration/PublishingExpression.cs

@@ -116,6 +116,8 @@ public PublishingExpression Message(Type type)
     /// <returns></returns>
     public PublishingExpression MessagesFromNamespace(string @namespace)
     {
+        AutoAddSubscriptions = true;
+
         _subscriptions.Add(new Subscription
         {
             Match = @namespace,
@@ -144,6 +146,7 @@ public PublishingExpression MessagesFromNamespaceContaining<T>()
     public PublishingExpression MessagesFromAssembly(Assembly assembly)
     {
         _subscriptions.Add(new Subscription(assembly));
+        AutoAddSubscriptions = true;
         return this;
     }