Refactor

README.md

@@ -49,8 +49,8 @@ const bus = await builder.build();
 await bus.start();
 
 // Send a message
-const transaction = await bus.createTransaction();
-transaction.addOutgoingMessage({ type: 'UserCreated', userId: 123 });
+const transaction = await bus.createOutgoingTransaction();
+transaction.add({ type: 'UserCreated', userId: 123 });
 await transaction.commit();
 
 await bus.stop();
@@ -75,8 +75,8 @@ bus = await builder.build()
 await bus.start()
 
 # Send a message
-transaction = await bus.create_transaction()
-transaction.add_outgoing_message({'type': 'UserCreated', 'user_id': 123})
+transaction = await bus.create_outgoing_transaction()
+transaction.add({'type': 'UserCreated', 'user_id': 123})
 await transaction.commit()
 
 await bus.stop()
@@ -104,8 +104,8 @@ var bus = await builder.Build();
 await bus.Start();
 
 // Send a message
-var transaction = await bus.CreateTransaction();
-transaction.AddOutgoingMessage(new { Type = "UserCreated", UserId = 123 });
+var transaction = await bus.CreateOutgoingTransaction();
+transaction.Add(new { Type = "UserCreated", UserId = 123 });
 await transaction.Commit();
 
 await bus.Stop();

src/dotnet/PloyBus.Tests/PloyBus.Tests.csproj

@@ -8,6 +8,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.Logging" Version="10.0.0" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
     <PackageReference Include="NUnit" Version="4.4.0" />
     <PackageReference Include="NUnit.Analyzers" Version="4.11.2">

src/dotnet/PloyBus.Tests/Transport/InMemory/AlphaCommand.cs

@@ -0,0 +1,9 @@
+using PolyBus.Transport.Transactions.Messages;
+
+namespace PolyBus.Transport.InMemory;
+
+[MessageInfo(MessageType.Command, "alpha", "alpha-command", 1, 0, 0)]
+class AlphaCommand
+{
+    public required string Name { get; set; }
+}

src/dotnet/PloyBus.Tests/Transport/InMemory/AlphaEvent.cs

@@ -0,0 +1,9 @@
+using PolyBus.Transport.Transactions.Messages;
+
+namespace PolyBus.Transport.InMemory;
+
+[MessageInfo(MessageType.Event, "alpha", "alpha-event", 1, 0, 0)]
+class AlphaEvent
+{
+    public required string Name { get; set; }
+}