Aggiunta implementazione RabbitMQ Abstractions

Author: AngeloDotNet

src/NET6CustomLibrary/RabbitMQ/Abstractions/DefaultMessagingBuilder.cs

@@ -0,0 +1,11 @@
+namespace NET6CustomLibrary.RabbitMQ.Abstractions;
+
+internal class DefaultMessagingBuilder : IMessagingBuilder
+{
+    public IServiceCollection Services { get; }
+
+    public DefaultMessagingBuilder(IServiceCollection services)
+    {
+        Services = services;
+    }
+}

src/NET6CustomLibrary/RabbitMQ/Abstractions/IMessageReceiver.cs

@@ -0,0 +1,6 @@
+namespace NET6CustomLibrary.RabbitMQ.Abstractions;
+
+public interface IMessageReceiver<T> where T : class
+{
+    Task ReceiveAsync(T message, CancellationToken cancellationToken);
+}

src/NET6CustomLibrary/RabbitMQ/Abstractions/IMessageSender.cs

@@ -0,0 +1,6 @@
+namespace NET6CustomLibrary.RabbitMQ.Abstractions;
+
+public interface IMessageSender
+{
+    Task PublishAsync<T>(T message, int priority = 1) where T : class;
+}

src/NET6CustomLibrary/RabbitMQ/Abstractions/IMessagingBuilder.cs

@@ -0,0 +1,6 @@
+namespace NET6CustomLibrary.RabbitMQ.Abstractions;
+
+public interface IMessagingBuilder
+{
+    IServiceCollection Services { get; }
+}

src/NET6CustomLibrary/RabbitMQ/Abstractions/JsonOptions.cs

@@ -0,0 +1,9 @@
+namespace NET6CustomLibrary.RabbitMQ.Abstractions;
+
+internal static class JsonOptions
+{
+    public static JsonSerializerOptions Default { get; } = new(JsonSerializerDefaults.Web)
+    {
+        DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingDefault
+    };
+}

src/NET6CustomLibrary/RabbitMQ/Abstractions/QueueSettings.cs

@@ -0,0 +1,12 @@
+namespace NET6CustomLibrary.RabbitMQ.Abstractions;
+
+public class QueueSettings
+{
+    internal IList<(string Name, Type Type)> Queues { get; } = new List<(string, Type)>();
+
+    public void Add<T>(string queueName = null) where T : class
+    {
+        var type = typeof(T);
+        Queues.Add((queueName ?? type.FullName, type));
+    }
+}