From 4601fbc2c8f20497010a7d938a8a051efb88f004 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期二, 19 三月 2024 08:37:39 +0800
Subject: [PATCH] 删除mq示例
---
springboot-vue3/src/main/java/com/example/springboot/component/ModuleB.java | 17 ++++++++++++-----
1 files changed, 12 insertions(+), 5 deletions(-)
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/ModuleB.java b/springboot-vue3/src/main/java/com/example/springboot/component/ModuleB.java
index e4d6b44..25aa925 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/ModuleB.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/ModuleB.java
@@ -2,25 +2,32 @@
import com.rabbitmq.client.*;
+import java.util.HashMap;
+import java.util.Map;
+
public class ModuleB {
- private final static String QUEUE_NAME = "hangzhoumes";
+ private final static String QUEUE_NAME = "hangzhou2";
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 channel = connection.createChannel()) {
// 澹版槑闃熷垪
- 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);
+
// 鍒涘缓娑堣垂鑰�
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String receivedMessage = new String(delivery.getBody(), "UTF-8");
System.out.println(" [x] Received '" + receivedMessage + "'");
};
// 寮�濮嬫秷璐规秷鎭�
- channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {
- });
+ channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {
+ });
}
}
}
--
Gitblit v1.8.0