Skip to content

Commit

Permalink
refactor!: merge serializer project
Browse files Browse the repository at this point in the history
  • Loading branch information
@jose-sousa-8
jose-sousa-8 committed Sep 19, 2023
1 parent 85f2ab2 commit 874e0c1
Show file tree
Hide file tree
Showing 44 changed files with 46 additions and 80 deletions.
2 changes: 0 additions & 2 deletions samples/KafkaFlow.Sample.BatchOperations/KafkaFlow.Sample.BatchOperations.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,11 +22,9 @@

<ItemGroup>
<ProjectReference Include="..\..\src\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.BatchConsume\KafkaFlow.BatchConsume.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.LogHandler.Console\KafkaFlow.LogHandler.Console.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Microsoft.DependencyInjection\KafkaFlow.Microsoft.DependencyInjection.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.JsonCore\KafkaFlow.Serializer.JsonCore.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>

Expand Down
2 changes: 1 addition & 1 deletion samples/KafkaFlow.Sample.BatchOperations/PrintConsoleMiddleware.cs
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
using System;
using System.Linq;
using System.Threading.Tasks;
using KafkaFlow.BatchConsume;
using KafkaFlow.Middlewares.BatchConsume;

namespace KafkaFlow.Sample.BatchOperations;

Expand Down
2 changes: 1 addition & 1 deletion samples/KafkaFlow.Sample.BatchOperations/Program.cs
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
using System;
using System.Linq;
using KafkaFlow;
using KafkaFlow.BatchConsume;
using KafkaFlow.Middlewares.BatchConsume;
using KafkaFlow.Producers;
using KafkaFlow.Sample.BatchOperations;
using KafkaFlow.Serializer;
Expand Down
1 change: 0 additions & 1 deletion samples/KafkaFlow.Sample.ConsumerThrottling/KafkaFlow.Sample.ConsumerThrottling.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
<ProjectReference Include="..\..\src\KafkaFlow.LogHandler.Console\KafkaFlow.LogHandler.Console.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Microsoft.DependencyInjection\KafkaFlow.Microsoft.DependencyInjection.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.JsonCore\KafkaFlow.Serializer.JsonCore.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>
Expand Down
1 change: 0 additions & 1 deletion samples/KafkaFlow.Sample.FlowControl/KafkaFlow.Sample.FlowControl.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
<ProjectReference Include="..\..\src\KafkaFlow.LogHandler.Console\KafkaFlow.LogHandler.Console.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Microsoft.DependencyInjection\KafkaFlow.Microsoft.DependencyInjection.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.NewtonsoftJson\KafkaFlow.Serializer.NewtonsoftJson.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>

Expand Down
1 change: 0 additions & 1 deletion samples/KafkaFlow.Sample.PauseConsumerOnError/KafkaFlow.Sample.PauseConsumerOnError.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
<ProjectReference Include="..\..\src\KafkaFlow.LogHandler.Console\KafkaFlow.LogHandler.Console.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Microsoft.DependencyInjection\KafkaFlow.Microsoft.DependencyInjection.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.JsonCore\KafkaFlow.Serializer.JsonCore.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>
Expand Down
1 change: 0 additions & 1 deletion samples/KafkaFlow.Sample.SchemaRegistry/KafkaFlow.Sample.SchemaRegistry.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro\KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.SchemaRegistry.ConfluentJson\KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf\KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>
Expand Down
2 changes: 0 additions & 2 deletions samples/KafkaFlow.Sample/KafkaFlow.Sample.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,12 +19,10 @@
<ItemGroup>
<ProjectReference Include="..\..\src\KafkaFlow.Admin\KafkaFlow.Admin.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Compressor.Gzip\KafkaFlow.Compressor.Gzip.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Compressor\KafkaFlow.Compressor.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.LogHandler.Console\KafkaFlow.LogHandler.Console.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Microsoft.DependencyInjection\KafkaFlow.Microsoft.DependencyInjection.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.JsonCore\KafkaFlow.Serializer.JsonCore.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer.ProtobufNet\KafkaFlow.Serializer.ProtobufNet.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\..\src\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>
Expand Down
1 change: 0 additions & 1 deletion src/KafkaFlow.Admin/KafkaFlow.Admin.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.ProtobufNet\KafkaFlow.Serializer.ProtobufNet.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>
Expand Down
4 changes: 0 additions & 4 deletions src/KafkaFlow.BatchConsume/AssemblyInfo.cs
View file

This file was deleted.

14 changes: 0 additions & 14 deletions src/KafkaFlow.BatchConsume/KafkaFlow.BatchConsume.csproj
View file

This file was deleted.

2 changes: 0 additions & 2 deletions src/KafkaFlow.IntegrationTests/KafkaFlow.IntegrationTests.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -35,14 +35,12 @@
<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\KafkaFlow.Compressor.Gzip\KafkaFlow.Compressor.Gzip.csproj" />
<ProjectReference Include="..\KafkaFlow.Compressor\KafkaFlow.Compressor.csproj" />
<ProjectReference Include="..\KafkaFlow.Microsoft.DependencyInjection\KafkaFlow.Microsoft.DependencyInjection.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.JsonCore\KafkaFlow.Serializer.JsonCore.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.ProtobufNet\KafkaFlow.Serializer.ProtobufNet.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro\KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.SchemaRegistry.ConfluentJson\KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf\KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>
Expand Down
2 changes: 1 addition & 1 deletion src/KafkaFlow.SchemaRegistry/KafkaFlow.SchemaRegistry.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@

<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\KafkaFlow\KafkaFlow.csproj" />
</ItemGroup>

</Project>
2 changes: 2 additions & 0 deletions src/KafkaFlow.SchemaRegistry/SchemaRegistryTypeResolver.cs
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
using KafkaFlow.Serializer;

namespace KafkaFlow
{
using System;
Expand Down
1 change: 1 addition & 0 deletions ...fkaFlow.Serializer.SchemaRegistry.ConfluentAvro/ConsumerConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
{
using Confluent.SchemaRegistry;
using KafkaFlow.Configuration;
using KafkaFlow.Serializer;
using KafkaFlow.Serializer.SchemaRegistry;

/// <summary>
Expand Down
1 change: 0 additions & 1 deletion ...zer.SchemaRegistry.ConfluentAvro/KafkaFlow.Serializer.SchemaRegistry.ConfluentAvro.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@
<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\KafkaFlow.SchemaRegistry\KafkaFlow.SchemaRegistry.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
</ItemGroup>

<ItemGroup>
Expand Down
1 change: 1 addition & 0 deletions ...fkaFlow.Serializer.SchemaRegistry.ConfluentAvro/ProducerConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
using Confluent.SchemaRegistry;
using Confluent.SchemaRegistry.Serdes;
using KafkaFlow.Configuration;
using KafkaFlow.Serializer;
using KafkaFlow.Serializer.SchemaRegistry;

/// <summary>
Expand Down
1 change: 1 addition & 0 deletions ...fkaFlow.Serializer.SchemaRegistry.ConfluentJson/ConsumerConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
namespace KafkaFlow
{
using KafkaFlow.Configuration;
using KafkaFlow.Serializer;
using KafkaFlow.Serializer.SchemaRegistry;

/// <summary>
Expand Down
1 change: 0 additions & 1 deletion ...zer.SchemaRegistry.ConfluentJson/KafkaFlow.Serializer.SchemaRegistry.ConfluentJson.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\KafkaFlow.SchemaRegistry\KafkaFlow.SchemaRegistry.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
</ItemGroup>

</Project>
1 change: 1 addition & 0 deletions ...fkaFlow.Serializer.SchemaRegistry.ConfluentJson/ProducerConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
{
using Confluent.SchemaRegistry.Serdes;
using KafkaFlow.Configuration;
using KafkaFlow.Serializer;
using KafkaFlow.Serializer.SchemaRegistry;

/// <summary>
Expand Down
4 changes: 3 additions & 1 deletion ...low.Serializer.SchemaRegistry.ConfluentProtobuf/ConsumerConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
namespace KafkaFlow
using KafkaFlow.Serializer;

namespace KafkaFlow
{
using Confluent.SchemaRegistry;
using KafkaFlow.Configuration;
Expand Down
1 change: 0 additions & 1 deletion ...maRegistry.ConfluentProtobuf/KafkaFlow.Serializer.SchemaRegistry.ConfluentProtobuf.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,5 @@
<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Abstractions\KafkaFlow.Abstractions.csproj" />
<ProjectReference Include="..\KafkaFlow.SchemaRegistry\KafkaFlow.SchemaRegistry.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
</ItemGroup>
</Project>
4 changes: 3 additions & 1 deletion ...low.Serializer.SchemaRegistry.ConfluentProtobuf/ProducerConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
namespace KafkaFlow
using KafkaFlow.Serializer;

namespace KafkaFlow
{
using Confluent.SchemaRegistry;
using Confluent.SchemaRegistry.Serdes;
Expand Down
2 changes: 1 addition & 1 deletion src/KafkaFlow.UnitTests/BatchConsume/BatchConsumeMiddlewareTests.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ namespace KafkaFlow.UnitTests.BatchConsume
using System;
using System.Threading.Tasks;
using FluentAssertions;
using KafkaFlow.BatchConsume;
using KafkaFlow.Middlewares.BatchConsume;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using Moq;

Expand Down
3 changes: 0 additions & 3 deletions src/KafkaFlow.UnitTests/KafkaFlow.UnitTests.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,11 +31,8 @@
<ItemGroup>
<ProjectReference Include="..\KafkaFlow.Admin.WebApi\KafkaFlow.Admin.WebApi.csproj" />
<ProjectReference Include="..\KafkaFlow.Admin\KafkaFlow.Admin.csproj" />
<ProjectReference Include="..\KafkaFlow.BatchConsume\KafkaFlow.BatchConsume.csproj" />
<ProjectReference Include="..\KafkaFlow.Compressor\KafkaFlow.Compressor.csproj" />
<ProjectReference Include="..\KafkaFlow.LogHandler.Microsoft\KafkaFlow.LogHandler.Microsoft.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.JsonCore\KafkaFlow.Serializer.JsonCore.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer\KafkaFlow.Serializer.csproj" />
<ProjectReference Include="..\KafkaFlow.Serializer.NewtonsoftJson\KafkaFlow.Serializer.NewtonsoftJson.csproj" />
<ProjectReference Include="..\KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj" />
<ProjectReference Include="..\KafkaFlow\KafkaFlow.csproj" />
Expand Down
2 changes: 2 additions & 0 deletions src/KafkaFlow.UnitTests/Serializers/SerializerConsumerMiddlewareTests.cs
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
using KafkaFlow.Serializer;

namespace KafkaFlow.UnitTests.Serializers
{
using System;
Expand Down
2 changes: 2 additions & 0 deletions src/KafkaFlow.UnitTests/Serializers/SerializerProducerMiddlewareTests.cs
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
using KafkaFlow.Serializer;

namespace KafkaFlow.UnitTests.Serializers
{
using System.IO;
Expand Down
23 changes: 1 addition & 22 deletions src/KafkaFlow.sln
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,10 +27,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Abstractions", "K
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.TypedHandler", "KafkaFlow.TypedHandler\KafkaFlow.TypedHandler.csproj", "{E47EF9E0-A1C7-4FF0-AEC5-143F52ED0FBE}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Serializer", "KafkaFlow.Serializer\KafkaFlow.Serializer.csproj", "{B7197114-B1C7-49EC-8740-1E09233B2C40}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Compressor", "KafkaFlow.Compressor\KafkaFlow.Compressor.csproj", "{D29EC709-33DE-4045-8F3B-EC6619CDB429}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.IntegrationTests", "KafkaFlow.IntegrationTests\KafkaFlow.IntegrationTests.csproj", "{36F459F4-8323-472A-A8C5-8C9D89F92012}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Serializer.NewtonsoftJson", "KafkaFlow.Serializer.NewtonsoftJson\KafkaFlow.Serializer.NewtonsoftJson.csproj", "{FC622AB0-6481-4249-8D83-27BC39912103}"
Expand Down Expand Up @@ -59,8 +55,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Serializer.Schema
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Middlewares", "Middlewares", "{ED24B548-6F37-4283-A35B-F6015BFB7A34}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.BatchConsume", "KafkaFlow.BatchConsume\KafkaFlow.BatchConsume.csproj", "{C891D0DB-BE19-4D20-9E2F-61D413210F8D}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Sample.BatchOperations", "..\samples\KafkaFlow.Sample.BatchOperations\KafkaFlow.Sample.BatchOperations.csproj", "{DE8A8871-B19E-489D-8292-386A06A4CDFA}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KafkaFlow.Extensions.Hosting", "KafkaFlow.Extensions.Hosting\KafkaFlow.Extensions.Hosting.csproj", "{7913342E-80FD-4094-B892-18DAA2E6948F}"
Expand Down Expand Up @@ -125,14 +119,6 @@ Global
{E47EF9E0-A1C7-4FF0-AEC5-143F52ED0FBE}.Debug|Any CPU.Build.0 = Debug|Any CPU
{E47EF9E0-A1C7-4FF0-AEC5-143F52ED0FBE}.Release|Any CPU.ActiveCfg = Release|Any CPU
{E47EF9E0-A1C7-4FF0-AEC5-143F52ED0FBE}.Release|Any CPU.Build.0 = Release|Any CPU
{B7197114-B1C7-49EC-8740-1E09233B2C40}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{B7197114-B1C7-49EC-8740-1E09233B2C40}.Debug|Any CPU.Build.0 = Debug|Any CPU
{B7197114-B1C7-49EC-8740-1E09233B2C40}.Release|Any CPU.ActiveCfg = Release|Any CPU
{B7197114-B1C7-49EC-8740-1E09233B2C40}.Release|Any CPU.Build.0 = Release|Any CPU
{D29EC709-33DE-4045-8F3B-EC6619CDB429}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{D29EC709-33DE-4045-8F3B-EC6619CDB429}.Debug|Any CPU.Build.0 = Debug|Any CPU
{D29EC709-33DE-4045-8F3B-EC6619CDB429}.Release|Any CPU.ActiveCfg = Release|Any CPU
{D29EC709-33DE-4045-8F3B-EC6619CDB429}.Release|Any CPU.Build.0 = Release|Any CPU
{36F459F4-8323-472A-A8C5-8C9D89F92012}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{36F459F4-8323-472A-A8C5-8C9D89F92012}.Debug|Any CPU.Build.0 = Debug|Any CPU
{36F459F4-8323-472A-A8C5-8C9D89F92012}.Release|Any CPU.ActiveCfg = Release|Any CPU
Expand Down Expand Up @@ -173,10 +159,6 @@ Global
{2E63A019-F8AD-4EC3-A80A-F560DEC7C5B4}.Debug|Any CPU.Build.0 = Debug|Any CPU
{2E63A019-F8AD-4EC3-A80A-F560DEC7C5B4}.Release|Any CPU.ActiveCfg = Release|Any CPU
{2E63A019-F8AD-4EC3-A80A-F560DEC7C5B4}.Release|Any CPU.Build.0 = Release|Any CPU
{C891D0DB-BE19-4D20-9E2F-61D413210F8D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{C891D0DB-BE19-4D20-9E2F-61D413210F8D}.Debug|Any CPU.Build.0 = Debug|Any CPU
{C891D0DB-BE19-4D20-9E2F-61D413210F8D}.Release|Any CPU.ActiveCfg = Release|Any CPU
{C891D0DB-BE19-4D20-9E2F-61D413210F8D}.Release|Any CPU.Build.0 = Release|Any CPU
{DE8A8871-B19E-489D-8292-386A06A4CDFA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{DE8A8871-B19E-489D-8292-386A06A4CDFA}.Debug|Any CPU.Build.0 = Debug|Any CPU
{DE8A8871-B19E-489D-8292-386A06A4CDFA}.Release|Any CPU.ActiveCfg = Release|Any CPU
Expand Down Expand Up @@ -238,9 +220,6 @@ Global
{ADAAA63C-E17C-4F1B-A062-3CCA071D75C2} = {ED24B548-6F37-4283-A35B-F6015BFB7A34}
{0A782A83-B66D-4B99-9BE2-2B18AAD2E03C} = {ED24B548-6F37-4283-A35B-F6015BFB7A34}
{88808771-56BE-422B-94DC-7AB070F64E98} = {068CB250-2804-4C7E-9490-17F432B9CE21}
{E47EF9E0-A1C7-4FF0-AEC5-143F52ED0FBE} = {ED24B548-6F37-4283-A35B-F6015BFB7A34}
{B7197114-B1C7-49EC-8740-1E09233B2C40} = {ADAAA63C-E17C-4F1B-A062-3CCA071D75C2}
{D29EC709-33DE-4045-8F3B-EC6619CDB429} = {0A782A83-B66D-4B99-9BE2-2B18AAD2E03C}
{36F459F4-8323-472A-A8C5-8C9D89F92012} = {7A9B997B-DAAC-4004-94F3-32F6B88E0068}
{FC622AB0-6481-4249-8D83-27BC39912103} = {ADAAA63C-E17C-4F1B-A062-3CCA071D75C2}
{B86A51E3-7AC9-4EF8-BD2A-1ACC9EF0F5AE} = {292BCEDD-55B4-49BB-B8B2-24CD834FF2AA}
Expand All @@ -251,7 +230,6 @@ Global
{827620D3-2258-410E-A79E-E782ED42284C} = {58483813-0D7C-423E-8E7D-8FBF3E6CDB6D}
{15C12D0C-FE8A-41F9-BBCF-5A963F05D5C7} = {303AE78F-6C96-4DF4-AC89-5C4FD53AFF0B}
{2E63A019-F8AD-4EC3-A80A-F560DEC7C5B4} = {ADAAA63C-E17C-4F1B-A062-3CCA071D75C2}
{C891D0DB-BE19-4D20-9E2F-61D413210F8D} = {ED24B548-6F37-4283-A35B-F6015BFB7A34}
{DE8A8871-B19E-489D-8292-386A06A4CDFA} = {303AE78F-6C96-4DF4-AC89-5C4FD53AFF0B}
{7913342E-80FD-4094-B892-18DAA2E6948F} = {068CB250-2804-4C7E-9490-17F432B9CE21}
{98C9826C-76F6-4C21-8A32-D55C2647905B} = {ADAAA63C-E17C-4F1B-A062-3CCA071D75C2}
Expand All @@ -264,6 +242,7 @@ Global
{8EAF0D96-F760-4FEF-9237-92779F66482D} = {EF626895-FDAE-4B28-9110-BA85671CBBF2}
{B4A9E7CE-7A37-411E-967E-D9B5FD1A3992} = {303AE78F-6C96-4DF4-AC89-5C4FD53AFF0B}
{4A16F519-FAF8-432C-AD0A-CC44F7BD392D} = {303AE78F-6C96-4DF4-AC89-5C4FD53AFF0B}
{E47EF9E0-A1C7-4FF0-AEC5-143F52ED0FBE} = {068CB250-2804-4C7E-9490-17F432B9CE21}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {6AE955B5-16B0-41CF-9F12-66D15B3DD1AB}
Expand Down
0 ...ompressor/CompressorConsumerMiddleware.cs → ...ompressor/CompressorConsumerMiddleware.cs
View file
File renamed without changes.
0 ...ompressor/CompressorProducerMiddleware.cs → ...ompressor/CompressorProducerMiddleware.cs
View file
File renamed without changes.
0 ...pressor/ConfigurationBuilderExtensions.cs → ...pressor/ConfigurationBuilderExtensions.cs
View file
File renamed without changes.
7 changes: 7 additions & 0 deletions src/KafkaFlow/KafkaFlow.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
<ItemGroup>
<PackageReference Include="Confluent.Kafka" Version="2.1.1" />
<PackageReference Include="System.Threading.Channels" Version="6.0.0" />
<PackageReference Include="System.Memory" Version="4.5.5" />
</ItemGroup>

<ItemGroup>
Expand All @@ -20,4 +21,10 @@
<_Parameter1>$(AssemblyName).UnitTests</_Parameter1>
</AssemblyAttribute>
</ItemGroup>

<ItemGroup>
<Reference Include="Microsoft.IO.RecyclableMemoryStream">
<HintPath>..\..\..\..\.nuget\packages\microsoft.io.recyclablememorystream\2.1.3\lib\netstandard2.0\Microsoft.IO.RecyclableMemoryStream.dll</HintPath>
</Reference>
</ItemGroup>
</Project>
2 changes: 1 addition & 1 deletion ...ow.BatchConsume/BatchConsumeExtensions.cs → ...es/BatchConsume/BatchConsumeExtensions.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow.BatchConsume
namespace KafkaFlow.Middlewares.BatchConsume
{
using System;
using System.Collections.Generic;
Expand Down
2 changes: 1 addition & 1 deletion ...atchConsume/BatchConsumeMessageContext.cs → ...atchConsume/BatchConsumeMessageContext.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow.BatchConsume
namespace KafkaFlow.Middlewares.BatchConsume
{
using System;
using System.Collections.Generic;
Expand Down
2 changes: 1 addition & 1 deletion ...ow.BatchConsume/BatchConsumeMiddleware.cs → ...es/BatchConsume/BatchConsumeMiddleware.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow.BatchConsume
namespace KafkaFlow.Middlewares.BatchConsume
{
using System;
using System.Collections.Generic;
Expand Down
2 changes: 1 addition & 1 deletion ...alizer/AsyncMessageTypeResolverWrapper.cs → ...alizer/AsyncMessageTypeResolverWrapper.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow
namespace KafkaFlow.Serializer
{
using System;
using System.Threading.Tasks;
Expand Down
2 changes: 1 addition & 1 deletion ...ddlewareConfigurationBuilderExtensions.cs → ...ddlewareConfigurationBuilderExtensions.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow
namespace KafkaFlow.Serializer
{
using System;
using KafkaFlow.Configuration;
Expand Down
6 changes: 3 additions & 3 deletions ...fkaFlow.Serializer/DefaultTypeResolver.cs → ...fkaFlow/Serializer/DefaultTypeResolver.cs
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
namespace KafkaFlow
{
using System;
using System;

namespace KafkaFlow.Serializer
{
internal class DefaultTypeResolver : IMessageTypeResolver
{
private const string MessageType = "Message-Type";
Expand Down
2 changes: 1 addition & 1 deletion ...w.Serializer/IAsyncMessageTypeResolver.cs → ...w/Serializer/IAsyncMessageTypeResolver.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow
namespace KafkaFlow.Serializer
{
using System;
using System.Threading.Tasks;
Expand Down
6 changes: 3 additions & 3 deletions ...kaFlow.Serializer/IMessageTypeResolver.cs → ...kaFlow/Serializer/IMessageTypeResolver.cs
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
namespace KafkaFlow
{
using System;
using System;

namespace KafkaFlow.Serializer
{
/// <summary>
/// Used by the serializer middleware to resolve the type when consuming and store it when producing
/// </summary>
Expand Down
2 changes: 1 addition & 1 deletion ...ProducerMiddlewareConfigurationBuilder.cs → ...ProducerMiddlewareConfigurationBuilder.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow
namespace KafkaFlow.Serializer
{
using System;
using KafkaFlow.Configuration;
Expand Down
2 changes: 1 addition & 1 deletion ...erializer/SerializerConsumerMiddleware.cs → ...erializer/SerializerConsumerMiddleware.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace KafkaFlow
namespace KafkaFlow.Serializer
{
using System;
using System.IO;
Expand Down
Loading

0 comments on commit 874e0c1

Please sign in to comment.