Refactor message handling interfaces and add new transport abstractions

.github/workflows/ci.yml

@@ -2,9 +2,9 @@ name: CI
 
 on:
   push:
-    branches: [ main, develop ]
+    branches: [ main ]
   pull_request:
-    branches: [ main, develop ]
+    branches: [ main ]
 
 jobs:
   build-and-test:

UltraSpeedBus.Abstractions/Message/ICommand.cs

@@ -1,3 +1,6 @@
 namespace UltraSpeedBus.Abstractions.Message;
 
+/// <summary>
+/// Command message marker interface
+/// </summary>
 public interface ICommand : IMessage {}

UltraSpeedBus.Abstractions/Message/ICommandHandler.cs

@@ -0,0 +1,7 @@
+namespace UltraSpeedBus.Abstractions.Message;
+
+public interface ICommandHandler<TCommand>
+    where TCommand : ICommand
+{
+    Task HandleAsync(TCommand command, CancellationToken cancellationToken);
+}

UltraSpeedBus.Abstractions/Message/IEvent.cs

@@ -1,3 +1,6 @@
 namespace UltraSpeedBus.Abstractions.Message;
 
+/// <summary>
+/// Event message marker interface
+/// </summary>
 public interface IEvent : IMessage {}

UltraSpeedBus.Abstractions/Message/IEventHandler.cs

@@ -0,0 +1,7 @@
+namespace UltraSpeedBus.Abstractions.Message;
+
+public interface IEventHandler<TEvent>
+    where TEvent : IEvent
+{
+    Task HandleAsync(TEvent @event, CancellationToken cancellationToken);
+}

UltraSpeedBus.Abstractions/Message/IMessage.cs

@@ -1,42 +1,14 @@
 namespace UltraSpeedBus.Abstractions.Message;
 
-// Message base interface
 public interface IMessage
 {
+    /// <summary>
+    /// It will be used for Saga, Idempotency, etc.
+    /// </summary>
     Guid MessageId { get; }
-    DateTime Timestamp { get; }
-
-}
-
-// Pipelines and middlewares
-public interface IMessageMiddleware
-{
-}
-
-public interface IPublishPipeline
-{
-}
-
-public interface IConsumerPipeline
-{
-}
 
-// Policies and erros
-public interface IErrorHandler
-{
-}
-
-public interface IRetryPolicy
-{
-}
-
-public interface IExceptionFilter
-{
-
-}
-
-// Telemetry - it will be integrated with OpenTelemetry
-public interface ITracerAdapter
-{
-
+    /// <summary>
+    /// It will be used for logging, tracing, etc.
+    /// </summary>
+    DateTime Timestamp { get; }
 }

UltraSpeedBus.Abstractions/Message/IQuery.cs

@@ -0,0 +1,3 @@
+namespace UltraSpeedBus.Abstractions.Message;
+
+public interface IQuery<TResult> : IMessage {}

UltraSpeedBus.Abstractions/Message/IQueryHandler.cs

@@ -0,0 +1,7 @@
+namespace UltraSpeedBus.Abstractions.Message;
+
+public interface IQueryHandler<TQuery, TResult>
+    where TQuery : IQuery<TResult>
+{
+    Task HandleAsync(TQuery query, CancellationToken cancellationToken);
+}

UltraSpeedBus.Abstractions/Transport/ITransport.cs

@@ -0,0 +1,7 @@
+namespace UltraSpeedBus.Abstractions.Message;
+
+public interface ITransport
+{
+    ITransportProducer CreateProducer();
+    ITransportConsumer CreateConsumer(string queueOrTopic);
+}

UltraSpeedBus.Abstractions/Transport/ITransportConsumer.cs

@@ -1,7 +1,23 @@
-namespace UltraSpeedBus.Abstractions.Transport;
+namespace UltraSpeedBus.Abstractions.Message;
 
+/// <summary>
+/// Represents a transport-agnostic consumer interface that supports multiple message consumption patterns:
+/// - Long polling (e.g., AWS SQS)
+/// - Push-based delivery (e.g., Azure Service Bus)
+/// - Subscription streaming (e.g., Apache Kafka)
+/// - Polling loop (e.g., Redis Streams)
+/// </summary>
 public interface ITransportConsumer : IAsyncDisposable
 {
-    Task StartAsync(Func<ConsumerTransportContext, Task> onMessage, CancellationToken cancellationToken = default);
-    Task StopAsync(CancellationToken cancellationToken = default);
+    Task InitializeAsync(CancellationToken cancellationToken = default);
+
+    Task StartConsumingAsync(
+        Func<ConsumerTransportContext, Task> handler,
+        CancellationToken cancellationToken = default);
+
+    Task StopConsumingAsync(CancellationToken cancellationToken = default);
 }
+
+public class ConsumerTransportContext
+{
+}

UltraSpeedBus.Abstractions/Transport/ITransportProducer.cs

@@ -1,12 +1,20 @@
-using UltraSpeedBus.Abstractions.Message;
+namespace UltraSpeedBus.Abstractions.Message;
 
-namespace UltraSpeedBus.Abstractions.Transport;
+public class MessageEnvelope
+{
+    public Guid MessageId { get; init; }
+    public string MessageType { get; init; } = null!;
+    public byte[] Payload { get; init; } = null!;
+}
 
+/// <summary>
+/// Defines a transport producer capable of sending and publishing messages.
+/// it will be used for Azure Service Bus, AWS, RabbitMQ fanout, SQS, Redis Streams, etc.
+/// </summary>
 public interface ITransportProducer : IAsyncDisposable
 {
-    Task StartAsync(CancellationToken cancellationToken = default);
-    Task StopAsync(CancellationToken cancellationToken = default);
+    Task InitializeAsync(CancellationToken cancellationToken = default);
 
-    Task SendAsync(MessageEnvelope envolope, CancellationToken cancellationToken = default);
-    Task PublishAsync(MessageEnvelope envolope, CancellationToken cancellationToken = default);
-}
+    Task SendAsync(string queue, MessageEnvelope envelop, CancellationToken cancellationToken = default);
+    Task PublishAsync(string topic, MessageEnvelope envelop, CancellationToken cancellationToken = default);
+}