Release/v5.2.0 (#88)

* Introduced SendDispatch methods on DispatchSender

* Changed version to 5.2.0

Author: kczarnecki-ecovadis

docs/CHANGELOG.md

@@ -3,6 +3,10 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+## 5.2.0
+- Added
+  - Introduced SendDispatch methods on DispatchSender. Those methods allow to send single message bigger than 1MB
+
 ## 5.1.5
 - Changed
   - skip transaction renaming when ServiceBus instrumentation is missing

src/Ev.ServiceBus.Abstractions/IDispatchSender.cs

@@ -7,6 +7,24 @@ namespace Ev.ServiceBus.Abstractions;
 
 public interface IDispatchSender
 {
+    /// <summary>
+    /// Immediately serializes object to message and sends it through ServiceBus.
+    /// Single message on Premium tier can be bigger than 1MB.
+    /// </summary>
+    /// <param name="messagePayload"></param>
+    /// <param name="token"></param>
+    /// <returns></returns>
+    Task SendDispatch(object messagePayload, CancellationToken token = default);
+
+    /// <summary>
+    /// Immediately serializes object to message and sends it through ServiceBus.
+    /// Single message on Premium tier can be bigger than 1MB.
+    /// </summary>
+    /// <param name="messagePayload"></param>
+    /// <param name="token"></param>
+    /// <returns></returns>
+    Task SendDispatch(Dispatch messagePayload, CancellationToken token = default);
+
     /// <summary>
     /// Immediately serializes object to messages and sends them through ServiceBus.
     /// (This is used internally by <see cref="IMessageDispatcher.ExecuteDispatches"/>)

src/Ev.ServiceBus/Dispatch/DispatchSender.cs

@@ -34,6 +34,27 @@ public DispatchSender(
         _dispatchCustomizers = dispatchCustomizers;
     }
 
+    /// <inheritdoc />
+    public async Task SendDispatch(object messagePayload, CancellationToken token = default)
+    {
+        var dispatch = new Abstractions.Dispatch(messagePayload);
+
+        await SendDispatch(dispatch, token);
+    }
+
+    /// <inheritdoc />
+    public async Task SendDispatch(Abstractions.Dispatch messagePayload, CancellationToken token = default)
+    {
+        var dispatches = CreateMessagesToSend([messagePayload]);
+
+        foreach (var messagePerResource in dispatches)
+        {
+            var message = messagePerResource.Messages.Single();
+
+            await messagePerResource.Sender.SendMessageAsync(message.Message, token);
+        }
+    }
+
     /// <inheritdoc />
     public async Task SendDispatches(IEnumerable<object> messagePayloads, CancellationToken token = default)
     {

tests/Ev.ServiceBus.UnitTests/DispatchTest.cs

@@ -396,6 +396,45 @@ await Assert.ThrowsAsync<ArgumentNullException>(
         }
     }
 
+    [Fact]
+    public async Task SendDispatch()
+    {
+        // configure
+        var services = new ServiceCollection();
+        services.AddServiceBus(settings =>
+        {
+            settings.WithConnection("myConnection", new ServiceBusClientOptions());
+        });
+        services.OverrideClientFactory();
+        services.RegisterServiceBusDispatch().ToQueue("myQueue", builder =>
+        {
+            builder.RegisterDispatch<SubscribedEvent>();
+        });
+        var provider = services.BuildServiceProvider();
+        await provider.SimulateStartHost(CancellationToken.None);
+
+        // Act
+        var message = new SubscribedEvent
+        {
+            SomeNumber = 1,
+            SomeString = "Event number 1"
+        };
+
+        using (var scope = provider.CreateScope())
+        {
+            var eventPublisher = scope.ServiceProvider.GetRequiredService<IDispatchSender>();
+            await eventPublisher.SendDispatch(message);
+        }
+
+        // Verify
+        var factory = provider.GetRequiredService<FakeClientFactory>();
+        var mock = factory.GetSenderMock("myQueue");
+        mock.Mock.Verify(o => o.SendMessageAsync(It.IsAny<ServiceBusMessage>(), It.IsAny<CancellationToken>()), Times.Exactly(1));
+
+        // Dispose
+        await provider.SimulateStopHost(CancellationToken.None);
+    }
+
     [Fact]
     public async Task SendDispatchesPaginateMessages()
     {