From dbeb2246aa7ce5aef8c3bfd15a7722ef6cdacedc Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期二, 23 四月 2024 10:57:55 +0800
Subject: [PATCH] 修改出片接片地址 限制，隐藏A01 A02未回零
---
springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java | 19 ++++++++++++++++---
1 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java b/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java
index 5a3d2f9..190a1cc 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java
@@ -2,13 +2,23 @@
import com.rabbitmq.client.*;
+import java.util.HashMap;
+import java.util.Map;
+
public class ModuleA {
- private final static String QUEUE_NAME = "hangzhoumes";
+ private static String QUEUE_NAME = "hangzhou2";
+
+ public ModuleA(String QUEUENAME){
+ QUEUE_NAME=QUEUENAME;
+ }
+
+
public static void main(String[] argv) throws Exception {
// 鍒涘缓杩炴帴宸ュ巶
ConnectionFactory factory = new ConnectionFactory();
- factory.setHost("localhost");
+ factory.setHost("10.153.19.150");
+ // factory.setHost("localhost");
try (Connection connection = factory.newConnection();
//channel 鏄�氳繃 connection 鍒涘缓鐨勪竴涓� AMQP 淇￠亾瀵硅薄
@@ -21,7 +31,10 @@
//4. `false`锛氭寚瀹氭槸鍚﹀湪涓嶅啀浣跨敤鏃惰嚜鍔ㄥ垹闄ら槦鍒椼�傚湪杩欓噷璁剧疆涓篳false`锛岃〃绀哄綋娌℃湁娑堣垂鑰呮垨鑰呮墍鏈夋秷璐硅�呮柇寮�杩炴帴鍚庯紝闃熷垪涓嶄細鑷姩鍒犻櫎銆�
//5. `null`锛氭寚瀹氬叾浠栭槦鍒楀睘鎬х殑鍙傛暟銆傚湪杩欓噷璁剧疆涓篳null`锛岃〃绀烘病鏈夊叾浠栧睘鎬ч渶瑕佽缃��
//鎵ц`channel.queueDeclare()`鏂规硶鍚庯紝濡傛灉闃熷垪涓嶅瓨鍦紝灏嗕細鍒涘缓涓�涓柊鐨勯槦鍒楋紝濡傛灉闃熷垪宸茬粡瀛樺湪锛屽垯涓嶅仛浠讳綍鎿嶄綔銆�
- channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+ Map<String, Object> args = new HashMap<>();
+ args.put("x-max-length", 10000);
+ channel.queueDeclare(QUEUE_NAME, true, false, false, args);
+
--
Gitblit v1.8.0