From 68bd30143b113f3231cc903872f47df6392c5759 Mon Sep 17 00:00:00 2001
From: zhangbin <460190368@qq.com>
Date: Mon, 18 Aug 2025 14:08:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E6=9C=AC=E5=9C=B0=E6=B5=8B?=
 =?UTF-8?q?=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../RabbitMQService/RabbitMqListenerService.cs | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs b/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs
index f88707d..91be8aa 100644
--- a/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs
+++ b/OpenAuth.WebApi/Model/RabbitMQService/RabbitMqListenerService.cs
@@ -17,14 +17,14 @@ namespace OpenAuth.WebApi.Model.RabbitMQService
         { 
             _factory = new ConnectionFactory
             {
-                //HostName = "123.132.248.154",
-                //UserName = "DHCloudg1",
-                //Password = "Cloud0#4fCraQrm",
-                //Port = 9103
-                HostName = "localhost",
-                UserName = "guest",
-                Password = "guest",
-                Port = 5672
+                HostName = "123.132.248.154",
+                UserName = "DHCloudg1",
+                Password = "Cloud0#4fCraQrm",
+                Port = 9103
+                //HostName = "localhost",
+                //UserName = "guest",
+                //Password = "guest",
+                //Port = 5672
             };
         }
         public async Task AddQueueBindingAsync(string exchange, string exchangeType, string routingKey)
@@ -45,7 +45,7 @@ namespace OpenAuth.WebApi.Model.RabbitMQService
         {
             _connection = await _factory.CreateConnectionAsync(stoppingToken);
             _channel = await _connection.CreateChannelAsync();
-            await BindQueueAsync(_channel, "processing_event", "topic", "event.trafficJunction.1.sdhc");
+            //await BindQueueAsync(_channel, "processing_event", "topic", "event.trafficJunction.1.sdhc");
             foreach (var binding in _bindings)
             {
                 await BindQueueAsync(_channel, binding.Exchange, binding.ExchangeType, binding.RoutingKey);