Simplify MassTransit sample

ServiceBuses/MassTransit/Cleipnir.Flows.MassTransit.Console/Cleipnir.Flows.MassTransit.Console.csproj

@@ -15,6 +15,7 @@
 
     <ItemGroup>
       <ProjectReference Include="..\..\..\Cleipnir.Flows\Cleipnir.Flows.csproj" />
+      <ProjectReference Include="..\..\..\SourceGeneration\Cleipnir.Flows.SourceGenerator\Cleipnir.Flows.SourceGenerator.csproj" OutputItemType="Analyzer" ReferenceOutputAssembly="false"/>
     </ItemGroup>
 
 </Project>

ServiceBuses/MassTransit/Cleipnir.Flows.MassTransit.Console/Program.cs

@@ -40,8 +40,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
             {
                 services.AddFlows(c => c
                     .UseInMemoryStore()
-                    .RegisterFlow<SimpleFlow, SimpleFlows>()
-                    //.RegisterFlowsAutomatically()
+                    .RegisterFlowsAutomatically()
                 );
 
                 services.AddMassTransit(x =>

ServiceBuses/MassTransit/Cleipnir.Flows.MassTransit.Console/SimpleFlow.cs

@@ -1,4 +1,5 @@
 using Cleipnir.ResilientFunctions.Reactive.Extensions;
+using MassTransit;
 
 namespace Cleipnir.Flows.MassTransit.Console;
 
@@ -9,4 +10,10 @@ public override async Task Run()
         var msg = await Messages.FirstOfType<MyMessage>();
         System.Console.WriteLine($"SimpleFlow({msg}) executed");
     }
-}
+}
+
+public class SimpleFlowsHandler(SimpleFlows simpleFlows) : IConsumer<MyMessage>
+{
+    public Task Consume(ConsumeContext<MyMessage> context) 
+        => simpleFlows.SendMessage(context.Message.Value, context.Message);
+}