v5.0.1 (#70)

Co-authored-by: Benjamin SPETH <bspeth@ecovadis.com>

Author: benspeth

src/Ev.ServiceBus.Abstractions/Configuration/ServiceBusOptions.cs

@@ -52,13 +52,13 @@ public ServiceBusOptions()
     /// </summary>
     public ReadOnlyCollection<MessageDispatchRegistration> DispatchRegistrations { get; }
 
-    /// <summary>
-    ///     Registers a queue that can be used to send or receive messages.
-    /// </summary>
-    /// <param name="queue">The name of the queue. It must be unique.</param>
-    internal void RegisterQueue(QueueOptions queue)
+    internal void RegisterQueueSender(QueueOptions queue)
     {
         _senders.Add(queue);
+    }
+
+    internal void RegisterQueueReceiver(QueueOptions queue)
+    {
         _receivers.Add(queue);
     }
 

src/Ev.ServiceBus/Dispatch/DispatchBuilder.cs

@@ -30,7 +30,7 @@ public void ToQueue(string queueName, Action<DispatchRegistrationBuilder> settin
         _services.Configure<ServiceBusOptions>(
             opts =>
             {
-                opts.RegisterQueue(queue);
+                opts.RegisterQueueSender(queue);
             });
         var builder = new DispatchRegistrationBuilder(_services, queue);
         settings(builder);

src/Ev.ServiceBus/Reception/ReceptionBuilder.cs

@@ -32,7 +32,7 @@ public void FromQueue(string queueName, Action<ReceptionRegistrationBuilder> set
         _services.Configure<ServiceBusOptions>(
             options =>
             {
-                options.RegisterQueue(queue);
+                options.RegisterQueueReceiver(queue);
             });
         var builder = new ReceptionRegistrationBuilder(_services, queue);
         settings(builder);

tests/Ev.ServiceBus.UnitTests/DispatchConfigurationTest.cs

@@ -137,6 +137,29 @@ public async Task CanRegisterSameTopicSenderTwice_Case2()
             });
     }
 
+    [Fact]
+    public async Task RegisteringAQueueDispatchWontRegisterAReceiver()
+    {
+        var composer = new Composer();
+
+        composer.WithAdditionalServices(services =>
+        {
+            services.RegisterServiceBusDispatch().ToQueue("queue", builder =>
+            {
+                builder.RegisterDispatch<PublishedEvent>();
+            });
+        });
+
+        await composer.Compose();
+
+        var registry = composer.Provider.GetRequiredService<ServiceBusRegistry>();
+        var senders = registry!.GetAllSenderClients();
+        senders.Length.Should().Be(1);
+        senders.First().EntityPath.Should().Be("queue");
+        var receiver = registry!.GetAllReceivers();
+        receiver.Length.Should().Be(0);
+    }
+
     [Fact]
     public async Task CanRegisterSameQueueSenderTwice()
     {
@@ -162,7 +185,6 @@ public async Task CanRegisterSameQueueSenderTwice()
         senders.First().EntityPath.Should().Be("queue");
     }
 
-
     [Fact]
     public async Task CanRegisterSameQueueSenderTwice_Case2()
     {