From 0a65c01a3a981dba1a02c7b260cc5c90ca903467 Mon Sep 17 00:00:00 2001 From: Christian Pauli Date: Thu, 16 Jul 2020 11:45:26 +0200 Subject: [PATCH] revert kafka inmem --- CAP.sln | 7 +++++++ .../Sample.Kafka.InMemory/Controllers/ValuesController.cs | 6 +++--- samples/Sample.Kafka.InMemory/Startup.cs | 2 +- 3 files changed, 11 insertions(+), 4 deletions(-) diff --git a/CAP.sln b/CAP.sln index 61cccbc..1b474a4 100644 --- a/CAP.sln +++ b/CAP.sln @@ -69,6 +69,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DotNetCore.CAP.AmazonSQS", EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DotNetCore.CAP.Pulsar", "src\DotNetCore.CAP.Pulsar\DotNetCore.CAP.Pulsar.csproj", "{73408EA6-1025-463C-88BC-A20769E44BC4}" EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Sample.PulsarInMemory", "samples\Sample.Pulsar.InMemory\Sample.PulsarInMemory.csproj", "{AFF0A34A-F938-4F75-9A96-9FC3DC0BF6DF}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -159,6 +161,10 @@ Global {73408EA6-1025-463C-88BC-A20769E44BC4}.Debug|Any CPU.Build.0 = Debug|Any CPU {73408EA6-1025-463C-88BC-A20769E44BC4}.Release|Any CPU.ActiveCfg = Release|Any CPU {73408EA6-1025-463C-88BC-A20769E44BC4}.Release|Any CPU.Build.0 = Release|Any CPU + {AFF0A34A-F938-4F75-9A96-9FC3DC0BF6DF}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {AFF0A34A-F938-4F75-9A96-9FC3DC0BF6DF}.Debug|Any CPU.Build.0 = Debug|Any CPU + {AFF0A34A-F938-4F75-9A96-9FC3DC0BF6DF}.Release|Any CPU.ActiveCfg = Release|Any CPU + {AFF0A34A-F938-4F75-9A96-9FC3DC0BF6DF}.Release|Any CPU.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE @@ -185,6 +191,7 @@ Global {2B0F467E-ABBD-4A51-BF38-D4F609DB6266} = {3A6B6931-A123-477A-9469-8B468B5385AF} {43475E00-51B7-443D-BC2D-FC21F9D8A0B4} = {9B2AE124-6636-4DE9-83A3-70360DABD0C4} {73408EA6-1025-463C-88BC-A20769E44BC4} = {9B2AE124-6636-4DE9-83A3-70360DABD0C4} + {AFF0A34A-F938-4F75-9A96-9FC3DC0BF6DF} = {3A6B6931-A123-477A-9469-8B468B5385AF} EndGlobalSection GlobalSection(ExtensibilityGlobals) = postSolution SolutionGuid = {2E70565D-94CF-40B4-BFE1-AC18D5F736AB} diff --git a/samples/Sample.Kafka.InMemory/Controllers/ValuesController.cs b/samples/Sample.Kafka.InMemory/Controllers/ValuesController.cs index 962b4c1..b382b41 100644 --- a/samples/Sample.Kafka.InMemory/Controllers/ValuesController.cs +++ b/samples/Sample.Kafka.InMemory/Controllers/ValuesController.cs @@ -18,13 +18,13 @@ namespace Sample.Kafka.InMemory.Controllers [Route("~/without/transaction")] public async Task WithoutTransaction() { - await _capBus.PublishAsync("persistent://public/default/supermatelsotoppic", DateTime.Now); + await _capBus.PublishAsync("sample.azure.mysql2", DateTime.Now); return Ok(); } - [CapSubscribe("persistent://public/default/supermatelsotoppic")] - public void Test2T2(string value) + [CapSubscribe("sample.azure.mysql2")] + public void Test2T2(DateTime value) { Console.WriteLine("Subscriber output message: " + value); } diff --git a/samples/Sample.Kafka.InMemory/Startup.cs b/samples/Sample.Kafka.InMemory/Startup.cs index e2845cb..ae3ee2a 100644 --- a/samples/Sample.Kafka.InMemory/Startup.cs +++ b/samples/Sample.Kafka.InMemory/Startup.cs @@ -10,7 +10,7 @@ namespace Sample.Kafka.InMemory services.AddCap(x => { x.UseInMemoryStorage(); - x.UsePulsar("pulsar://10.9.1.124:30398,10.9.1.124:30724,10.9.1.124:31771"); + x.UseKafka("localhost:9092"); x.UseDashboard(); });