From 90cbf7ae810140ec5d4df518784df14e7dd94e7d Mon Sep 17 00:00:00 2001 From: Reimar Date: Tue, 25 Mar 2025 12:54:52 +0100 Subject: [PATCH] Fix listening for AMQP messages, remove test console app --- backend/Api/AMQPReciever/AMQPReciever.cs | 3 +- backend/ConsoleApp1/ConsoleApp1.csproj | 14 ------- backend/ConsoleApp1/ConsoleApp1.sln | 25 ------------ backend/ConsoleApp1/Program.cs | 52 ------------------------ 4 files changed, 1 insertion(+), 93 deletions(-) delete mode 100644 backend/ConsoleApp1/ConsoleApp1.csproj delete mode 100644 backend/ConsoleApp1/ConsoleApp1.sln delete mode 100644 backend/ConsoleApp1/Program.cs diff --git a/backend/Api/AMQPReciever/AMQPReciever.cs b/backend/Api/AMQPReciever/AMQPReciever.cs index 0b6cf56..36b3a44 100644 --- a/backend/Api/AMQPReciever/AMQPReciever.cs +++ b/backend/Api/AMQPReciever/AMQPReciever.cs @@ -67,8 +67,7 @@ namespace Api.AMQPReciever await channel.BasicConsumeAsync(queue, true, consumer); - Console.WriteLine("Press enter to exit."); - Console.ReadLine(); + while (true); } } } diff --git a/backend/ConsoleApp1/ConsoleApp1.csproj b/backend/ConsoleApp1/ConsoleApp1.csproj deleted file mode 100644 index 7dfb515..0000000 --- a/backend/ConsoleApp1/ConsoleApp1.csproj +++ /dev/null @@ -1,14 +0,0 @@ - - - - Exe - net8.0 - enable - enable - - - - - - - diff --git a/backend/ConsoleApp1/ConsoleApp1.sln b/backend/ConsoleApp1/ConsoleApp1.sln deleted file mode 100644 index b1ff789..0000000 --- a/backend/ConsoleApp1/ConsoleApp1.sln +++ /dev/null @@ -1,25 +0,0 @@ - -Microsoft Visual Studio Solution File, Format Version 12.00 -# Visual Studio Version 17 -VisualStudioVersion = 17.9.34607.119 -MinimumVisualStudioVersion = 10.0.40219.1 -Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsoleApp1", "ConsoleApp1.csproj", "{0BC93CF2-F92D-4DD6-83BE-A985CBB74960}" -EndProject -Global - GlobalSection(SolutionConfigurationPlatforms) = preSolution - Debug|Any CPU = Debug|Any CPU - Release|Any CPU = Release|Any CPU - EndGlobalSection - GlobalSection(ProjectConfigurationPlatforms) = postSolution - {0BC93CF2-F92D-4DD6-83BE-A985CBB74960}.Debug|Any CPU.ActiveCfg = Debug|Any CPU - {0BC93CF2-F92D-4DD6-83BE-A985CBB74960}.Debug|Any CPU.Build.0 = Debug|Any CPU - {0BC93CF2-F92D-4DD6-83BE-A985CBB74960}.Release|Any CPU.ActiveCfg = Release|Any CPU - {0BC93CF2-F92D-4DD6-83BE-A985CBB74960}.Release|Any CPU.Build.0 = Release|Any CPU - EndGlobalSection - GlobalSection(SolutionProperties) = preSolution - HideSolutionNode = FALSE - EndGlobalSection - GlobalSection(ExtensibilityGlobals) = postSolution - SolutionGuid = {55EE0E94-4585-4E79-AC67-4B0E809E99AB} - EndGlobalSection -EndGlobal diff --git a/backend/ConsoleApp1/Program.cs b/backend/ConsoleApp1/Program.cs deleted file mode 100644 index a5e0e23..0000000 --- a/backend/ConsoleApp1/Program.cs +++ /dev/null @@ -1,52 +0,0 @@ -using RabbitMQ.Client; -using RabbitMQ.Client.Events; -using System.Text; - - -var factory = new ConnectionFactory(); -var queue = "test"; - - -factory.UserName = "h5"; -factory.Password = "Merc1234"; -factory.HostName = "10.135.51.116"; -factory.Port = 5672; - -using var conn = await factory.CreateConnectionAsync(); -Console.WriteLine("AMQPClien connected"); -using var channel = await conn.CreateChannelAsync(); - -await channel.QueueDeclareAsync(queue: queue, durable: false, exclusive: false, autoDelete: false); -Console.WriteLine($"{queue} connected"); - -var consumer = new AsyncEventingBasicConsumer(channel); -consumer.ReceivedAsync += (model, ea) => -{ - Console.WriteLine("Received application message."); - var body = ea.Body.ToArray(); - var message = Encoding.UTF8.GetString(body); - Console.WriteLine(message); - - return Task.CompletedTask; -}; - -await channel.BasicConsumeAsync(queue, true, consumer); - - -const string message = "Hello World!"; -var body = Encoding.UTF8.GetBytes(message); -await channel.BasicPublishAsync(exchange: string.Empty, routingKey: queue, body: body); -Console.WriteLine(" Press enter to continue."); -Console.ReadLine(); -await channel.BasicPublishAsync(exchange: string.Empty, routingKey: queue, body: body); -Console.WriteLine(" Press enter to continue."); -Console.ReadLine(); -await channel.BasicPublishAsync(exchange: string.Empty, routingKey: queue, body: body); -Console.WriteLine(" Press enter to continue."); -Console.ReadLine(); -await channel.BasicPublishAsync(exchange: string.Empty, routingKey: queue, body: body); -Console.WriteLine(" Press enter to continue."); -Console.ReadLine(); -await channel.BasicPublishAsync(exchange: string.Empty, routingKey: queue, body: body); -Console.WriteLine(" Press enter to exit."); -Console.ReadLine(); \ No newline at end of file