Develop

.vscode/launch.json

@@ -0,0 +1,35 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            // Use IntelliSense to find out which attributes exist for C# debugging
+            // Use hover for the description of the existing attributes
+            // For further information visit https://github.com/dotnet/vscode-csharp/blob/main/debugger-launchjson.md.
+            "name": ".NET Core Launch (web)",
+            "type": "coreclr",
+            "request": "launch",
+            "preLaunchTask": "build",
+            // If you have changed target frameworks, make sure to update the program path.
+            "program": "${workspaceFolder}/sample/UltraSpeedBus.WebAPI/bin/Debug/net8.0/UltraSpeedBus.WebAPI.dll",
+            "args": [],
+            "cwd": "${workspaceFolder}/sample/UltraSpeedBus.WebAPI",
+            "stopAtEntry": false,
+            // Enable launching a web browser when ASP.NET Core starts. For more information: https://aka.ms/VSCode-CS-LaunchJson-WebBrowser
+            "serverReadyAction": {
+                "action": "openExternally",
+                "pattern": "\\bNow listening on:\\s+(https?://\\S+)"
+            },
+            "env": {
+                "ASPNETCORE_ENVIRONMENT": "Development"
+            },
+            "sourceFileMap": {
+                "/Views": "${workspaceFolder}/Views"
+            }
+        },
+        {
+            "name": ".NET Core Attach",
+            "type": "coreclr",
+            "request": "attach"
+        }
+    ]
+}

.vscode/settings.json

@@ -0,0 +1 @@
+{}

.vscode/tasks.json

@@ -0,0 +1,53 @@
+{
+    "version": "2.0.0",
+    "tasks": [
+        {
+            "label": "build",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "build",
+                "${workspaceFolder}/sample/UltraSpeedBus.WebAPI/UltraSpeedBus.WebAPI.csproj",
+                "/property:GenerateFullPaths=true",
+                "/consoleloggerparameters:NoSummary;ForceNoAlign"
+            ],
+            "problemMatcher": "$msCompile"
+        },
+        {
+            "label": "build2",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "build",
+                "${workspaceFolder}/UltraSpeedBus.Abstractions/UltraSpeedBus.Abstractions.csproj",
+                "/property:GenerateFullPaths=true",
+                "/consoleloggerparameters:NoSummary;ForceNoAlign"
+            ],
+            "promptOnClose": false
+        },
+        {
+            "label": "publish",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "publish",
+                "${workspaceFolder}/sample/UltraSpeedBus.WebAPI/UltraSpeedBus.WebAPI.csproj",
+                "/property:GenerateFullPaths=true",
+                "/consoleloggerparameters:NoSummary;ForceNoAlign"
+            ],
+            "problemMatcher": "$msCompile"
+        },
+        {
+            "label": "watch",
+            "command": "dotnet",
+            "type": "process",
+            "args": [
+                "watch",
+                "run",
+                "--project",
+                "${workspaceFolder}/sample/UltraSpeedBus.WebAPI/UltraSpeedBus.WebAPI.csproj"
+            ],
+            "problemMatcher": "$msCompile"
+        }
+    ]
+}

README.md

@@ -7,6 +7,7 @@ UltraSpeedBus is a free, open-source messaging framework for .NET, engineered fo
 | ---------------------------- | --------------------------------------------------------------------------------------------- |
 | `UltraSpeedBus`              | The core library with message transport, context, pipelines, and integration implementations. |
 | `UltraSpeedBus.Abstractions` | Contains the core contracts, interfaces, and message envelope definitions for the system.     |
+| `UltraSpeedBus.Extensions.DependencyInjection` | Inject your dependencies |
 
 ## Features
 
@@ -23,18 +24,62 @@ UltraSpeedBus is a free, open-source messaging framework for .NET, engineered fo
 # Install the packages via NuGet
 dotnet add package UltraSpeedBus
 dotnet add package UltraSpeedBus.Abstractions
+dotnet add package UltraSpeedBus.Extensions.DependencyInjection
 ```
 
+## Command handler
+
 ```csharp
 using UltraSpeedBus;
 using UltraSpeedBus.Abstractions;
 
-// Create a message
-var message = new MyCommand { Name = "Test" };
-var envelope = MessageFactory.Create(message);
+// Create a command and command Handler with ICommandHandler
+public sealed record CreateOrderCommand(string Product, int Quantity);
+public sealed record OrderResult(int OrderId);
+
+public class CreateOrderHandler : ICommandHandler<CreateOrderCommand, OrderResult>
+{
+    public Task<OrderResult> Handle(CommandContext<CreateOrderCommand> request)
+    {
+        int generatedId = Random.Shared.Next(1000, 9999);
+        return Task.FromResult(new OrderResult(generatedId));
+    }
+}
+```
+
+## Query Handler
+
+```cs
+public sealed record GetOrderQuery(int OrderId);
+public sealed record OrderDto(int OrderId, string Description);
+
+public class GetOrderQueryHandler : IQueryHandler<GetOrderQuery, OrderDto?>
+{
+    public Task<OrderDto?> Handle(QueryContext<GetOrderQuery> context)
+    {
+        if (context.Query.OrderId == 42)
+        {
+            return Task.FromResult<OrderDto?>(new OrderDto(42, "Example Order"));
+        }
+
+        return Task.FromResult<OrderDto?>(null);
+    }
+}
+```
+
+## Event Handler
+
+```cs
+public sealed record OrderCreatedEvent(int OrderId);
 
-// Send using your transport implementation (e.g., Azure Service Bus)
-await producer.SendAsync(envelope);
+public class OrderCreatedEventHandler : IEventHandler<OrderCreatedEvent>
+{
+    public Task Handle(EventContext<OrderCreatedEvent> context)
+    {
+        Console.WriteLine($"[Event] Order created → Id = {context.Event.OrderId}");
+        return Task.CompletedTask;
+    }
+}
 ```
 
 ## Contributing

UltraSpeedBus.slnx

@@ -1,7 +1,11 @@
 <Solution>
+  <Folder Name="/sample/">
+    <Project Path="sample/UltraSpeedBus.WebAPI/UltraSpeedBus.WebAPI.csproj" />
+  </Folder>
   <Folder Name="/src/">
-    <Project Path="UltraSpeedBus.Abstractions/UltraSpeedBus.Abstractions.csproj" />
-    <Project Path="UltraSpeedBus.Tests/UltraSpeedBus.Tests.csproj" />
-    <Project Path="UltraSpeedBus/UltraSpeedBus.csproj" />
+    <Project Path="src/UltraSpeedBus.Abstractions/UltraSpeedBus.Abstractions.csproj" />
+    <Project Path="src/UltraSpeedBus.Tests/UltraSpeedBus.Tests.csproj" />
+    <Project Path="src/UltraSpeedBus/UltraSpeedBus.csproj" />
+    <Project Path="src/UltraSpeedBus.Extensions.DepedencyInjection/UltraSpeedBus.Extensions.DepedencyInjection.csproj" />
   </Folder>
 </Solution>

sample/UltraSpeedBus.WebAPI/CreateOrderHandler.cs

@@ -0,0 +1,51 @@
+using UltraSpeedBus.Abstractions;
+using UltraSpeedBus.Abstractions.Contracts;
+
+
+namespace UltraSpeedBus.WebAPI;
+
+
+#region Command
+public sealed record CreateOrder(string Product, int Quantity);
+public sealed record OrderResult(int OrderId);
+public sealed record OrderCreated(int OrderId);
+
+public class CreateOrderHandler : ICommandHandler<CreateOrder, OrderResult>
+{
+    public Task<OrderResult> Handle(CommandContext<CreateOrder> request)
+    {
+        // Simula criação de pedido
+        int generatedId = Random.Shared.Next(1000, 9999);
+
+        return Task.FromResult(new OrderResult(generatedId));
+    }
+}
+#endregion
+
+#region Query
+public sealed record GetOrder(int OrderId);
+public sealed record OrderDto(int OrderId, string Description);
+public class GetOrderQueryHandler : IQueryHandler<GetOrder, OrderDto?>
+{
+    public Task<OrderDto?> Handle(QueryContext<GetOrder> context)
+    {
+        if (context.Query.OrderId == 42)
+        {
+            return Task.FromResult<OrderDto?>(new OrderDto(42, "Example Order"));
+        }
+
+        return Task.FromResult<OrderDto?>(null);
+    }
+}
+#endregion
+
+#region Event
+public class OrderCreatedEventHandler : IEventHandler<OrderCreated>
+{
+    public Task Handle(EventContext<OrderCreated> context)
+    {
+        Console.WriteLine($"[Event] Order created → Id = {context.Event.OrderId}");
+        return Task.CompletedTask;
+    }
+}
+#endregion