Release v4.0.0

.editorconfig

@@ -42,6 +42,18 @@ csharp_prefer_simple_default_expression = true:suggestion
 # CA1859: Use concrete types when possible for improved performance
 dotnet_diagnostic.CA1859.severity = silent
 
+# IDE0008: Use explicit type
+dotnet_diagnostic.IDE0008.severity = none
+
+# IDE0019: Use pattern matching
+csharp_style_pattern_matching_over_as_with_null_check = false
+
+# IDE0058: Expression value is never used
+csharp_style_unused_value_expression_statement_preference = unused_local_variable
+
+# CA1806: Do not ignore method results
+dotnet_diagnostic.CA1806.severity = none
+
 [*.{cs,vb}]
 #### Naming styles ####
 

RabbitMQ.Dataflows.sln

@@ -30,8 +30,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HouseofCat.Serialization",
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HouseofCat.Hashing", "src\HouseofCat.Hashing\HouseofCat.Hashing.csproj", "{75C192B0-BCEC-4BAF-97F7-0F08209557FE}"
 EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HouseofCat.Metrics", "src\HouseofCat.Metrics\HouseofCat.Metrics.csproj", "{B475ECF4-6CAD-4FB7-80CF-0B8326BAD718}"
-EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "HouseofCat.Data", "src\HouseofCat.Data\HouseofCat.Data.csproj", "{2B4A8274-83BB-49FD-9E7C-AE1EB5C56B3A}"
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "guides", "guides", "{1AB5E832-AD36-40AF-A7E9-A105A778116C}"
@@ -86,6 +84,10 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "rabbitmq", "rabbitmq", "{5C
 		guides\rabbitmq\Serialization.md = guides\rabbitmq\Serialization.md
 	EndProjectSection
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "OpenTelemetry.Console.Tests", "tests\OpenTelemetry.Console.Tests\OpenTelemetry.Console.Tests.csproj", "{077E07C3-9A35-42A0-8228-E9778F02DFCE}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "RabbitMQ.ConsumerDataflowService", "tests\RabbitMQ.ConsumerDataflowService\RabbitMQ.ConsumerDataflowService.csproj", "{F6C0B657-E70B-4DE9-96AE-E7612C89AF5F}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -120,10 +122,6 @@ Global
 		{75C192B0-BCEC-4BAF-97F7-0F08209557FE}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{75C192B0-BCEC-4BAF-97F7-0F08209557FE}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{75C192B0-BCEC-4BAF-97F7-0F08209557FE}.Release|Any CPU.Build.0 = Release|Any CPU
-		{B475ECF4-6CAD-4FB7-80CF-0B8326BAD718}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{B475ECF4-6CAD-4FB7-80CF-0B8326BAD718}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{B475ECF4-6CAD-4FB7-80CF-0B8326BAD718}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{B475ECF4-6CAD-4FB7-80CF-0B8326BAD718}.Release|Any CPU.Build.0 = Release|Any CPU
 		{2B4A8274-83BB-49FD-9E7C-AE1EB5C56B3A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{2B4A8274-83BB-49FD-9E7C-AE1EB5C56B3A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{2B4A8274-83BB-49FD-9E7C-AE1EB5C56B3A}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -136,6 +134,14 @@ Global
 		{528C015E-58FC-44B4-BAC5-05BCFCD506C9}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{528C015E-58FC-44B4-BAC5-05BCFCD506C9}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{528C015E-58FC-44B4-BAC5-05BCFCD506C9}.Release|Any CPU.Build.0 = Release|Any CPU
+		{077E07C3-9A35-42A0-8228-E9778F02DFCE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{077E07C3-9A35-42A0-8228-E9778F02DFCE}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{077E07C3-9A35-42A0-8228-E9778F02DFCE}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{077E07C3-9A35-42A0-8228-E9778F02DFCE}.Release|Any CPU.Build.0 = Release|Any CPU
+		{F6C0B657-E70B-4DE9-96AE-E7612C89AF5F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{F6C0B657-E70B-4DE9-96AE-E7612C89AF5F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{F6C0B657-E70B-4DE9-96AE-E7612C89AF5F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{F6C0B657-E70B-4DE9-96AE-E7612C89AF5F}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -148,7 +154,6 @@ Global
 		{AF7AF28A-6704-4E62-9977-23E1FE1490D9} = {4FCA30F5-D19B-4756-BC68-6BA7E668F786}
 		{6AE8BE48-BA11-4120-B8F8-3D42CF56DD46} = {4FCA30F5-D19B-4756-BC68-6BA7E668F786}
 		{75C192B0-BCEC-4BAF-97F7-0F08209557FE} = {4FCA30F5-D19B-4756-BC68-6BA7E668F786}
-		{B475ECF4-6CAD-4FB7-80CF-0B8326BAD718} = {4FCA30F5-D19B-4756-BC68-6BA7E668F786}
 		{2B4A8274-83BB-49FD-9E7C-AE1EB5C56B3A} = {4FCA30F5-D19B-4756-BC68-6BA7E668F786}
 		{1AB5E832-AD36-40AF-A7E9-A105A778116C} = {29F4C0CA-2EA4-433C-8112-9A1336392E52}
 		{018DB970-F843-4D69-AAE1-C3CDF5FC7093} = {1AB5E832-AD36-40AF-A7E9-A105A778116C}
@@ -160,6 +165,8 @@ Global
 		{0930ACF5-372E-49AF-B53F-A06C3A5FA997} = {D01D59E9-75CC-4C74-A887-22B0A55C994B}
 		{528C015E-58FC-44B4-BAC5-05BCFCD506C9} = {D01D59E9-75CC-4C74-A887-22B0A55C994B}
 		{5C94F432-8229-4FFA-8DBF-AC1DEDE66265} = {1AB5E832-AD36-40AF-A7E9-A105A778116C}
+		{077E07C3-9A35-42A0-8228-E9778F02DFCE} = {D01D59E9-75CC-4C74-A887-22B0A55C994B}
+		{F6C0B657-E70B-4DE9-96AE-E7612C89AF5F} = {D01D59E9-75CC-4C74-A887-22B0A55C994B}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {D7099845-267C-4232-8764-5DF25D6B2C79}

common.props

@@ -8,28 +8,28 @@
 		<IsWindows Condition="'$([System.Runtime.InteropServices.RuntimeInformation]::IsOSPlatform($([System.Runtime.InteropServices.OSPlatform]::Windows)))' == 'true'">true</IsWindows>
 		<IsOSX Condition="'$([System.Runtime.InteropServices.RuntimeInformation]::IsOSPlatform($([System.Runtime.InteropServices.OSPlatform]::OSX)))' == 'true'">true</IsOSX>
 		<IsLinux Condition="'$([System.Runtime.InteropServices.RuntimeInformation]::IsOSPlatform($([System.Runtime.InteropServices.OSPlatform]::Linux)))' == 'true'">true</IsLinux>
-
+		
 		<!-- NuGet Attributes -->
 		<Authors>HouseofCat.io</Authors>
 		<Description>RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows.</Description>
 		<Copyright>Copyright © 2024</Copyright>
-		<Product>HouseofCat.io - RabbitMQ.Workflows</Product>
+		<Product>HouseofCat.io - RabbitMQ.Dataflows</Product>
 		<PackageIcon>houseofcat.png</PackageIcon>
 		<PackageTags>C# NET8 NetCore RabbitMQ HouseofCat HouseofCat.io TPL Workflows Dataflow Pipelines</PackageTags>
 		<PackageReleaseNotes>Major overhaul!</PackageReleaseNotes>
-    <PackageReadmeFile>README.md</PackageReadmeFile>
-    <PackageLicenseFile>LICENSE</PackageLicenseFile>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+		<PackageLicenseFile>LICENSE</PackageLicenseFile>
 		<PackageProjectUrl>https://github.com/houseofcat/RabbitMQ.Dataflows</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/houseofcat/RabbitMQ.Dataflows</RepositoryUrl>
 		<RepositoryType>git</RepositoryType>
-
+		
 		<!-- Sourcelink-->
 		<PublishRepositoryUrl>true</PublishRepositoryUrl>
 		<EmbedAllSources>true</EmbedAllSources>
 		<IncludeSymbols>true</IncludeSymbols>
 		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
 		<AllowedOutputExtensionsInPackageBuildOutputFolder>$(AllowedOutputExtensionsInPackageBuildOutputFolder);.pdb</AllowedOutputExtensionsInPackageBuildOutputFolder>
-
+		
 		<!-- Analyze -->
 		<RunAnalyzersDuringBuild>true</RunAnalyzersDuringBuild>
 		<RunAnalyzersDuringLiveAnalysis>true</RunAnalyzersDuringLiveAnalysis>
@@ -59,14 +59,14 @@
 			<Pack>True</Pack>
 			<PackagePath></PackagePath>
 		</None>
-    <None Include="..\..\LICENSE">
-      <Pack>True</Pack>
-      <PackagePath></PackagePath>
-    </None>
-    <None Include="..\..\README.md">
-      <Pack>True</Pack>
-      <PackagePath></PackagePath>
-    </None>
+		<None Include="..\..\LICENSE">
+			<Pack>True</Pack>
+			<PackagePath></PackagePath>
+		</None>
+			<None Include="..\..\README.md">
+			<Pack>True</Pack>
+			<PackagePath></PackagePath>
+		</None>
 	</ItemGroup>
 
 	<ItemGroup>

guides/csharp/TasksBranchExecution.md

@@ -154,7 +154,7 @@ namespace Tasks
             // All my messages, assigned to a Task assigned inside an array.
             // Execution of each task begins when created but there is no blocking here.
             var tasks = new Task[myStrings.Count];
-            for (int i = 0; i < myStrings.Count; i++)
+            for (var i = 0; i < myStrings.Count; i++)
             {
                 tasks[i] = ProcessMessageAsync(myStrings[i]);
             }