From 04adb88a2ed54cdf4c2958c79972c30109b9b5b6 Mon Sep 17 00:00:00 2001
From: wang <3597712270@qq.com>
Date: 星期四, 28 三月 2024 16:54:56 +0800
Subject: [PATCH] 内容调整
---
UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java | 61 ++++++++++++++++++------------
1 files changed, 36 insertions(+), 25 deletions(-)
diff --git a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
index f4c49d7..2cd57e4 100644
--- a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
+++ b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
@@ -1,38 +1,49 @@
package com.mes.service;
-import com.rabbitmq.client.Channel;
-import com.rabbitmq.client.Connection;
-import com.rabbitmq.client.ConnectionFactory;
-import com.rabbitmq.client.DeliverCallback;
+import com.mes.common.RabbitMQUtils;
-import java.util.HashMap;
-import java.util.Map;
+import java.util.List;
public class ModuleB {
private final static String QUEUE_NAME = "hangzhou2";
public static void main(String[] argv) throws Exception {
- // 鍒涘缓杩炴帴宸ュ巶
- ConnectionFactory factory = new ConnectionFactory();
- factory.setHost("10.153.19.150");
- //factory.setHost("localhost");
- try (Connection connection = factory.newConnection();
- Channel channel = connection.createChannel()) {
- // 澹版槑闃熷垪
- Map<String, Object> args = new HashMap<>();
- args.put("x-max-length-bytes",20000);
-// args.put("x-max-length",5000);
- channel.queueDeclare(QUEUE_NAME, false, 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 -> {
- });
+
+
+ RabbitMQUtils receiver = new RabbitMQUtils();
+
+ try {
+
+ //receiver.consumeMessageById("5",QUEUE_NAME);
+
+ // String receivedMessage = receiver.consumeSelectedMessage(1,QUEUE_NAME);
+ List<String> receivedMessage = receiver.browseMessages(QUEUE_NAME);
+ System.out.println("Received message: " + receivedMessage);
+ } catch (Exception e) {
+ e.printStackTrace();
}
+// // 鍒涘缓杩炴帴宸ュ巶
+// ConnectionFactory factory = new ConnectionFactory();
+// factory.setHost("10.153.19.150");
+// //factory.setHost("localhost");
+// try (Connection connection = factory.newConnection();
+// Channel channel = connection.createChannel()) {
+// // 澹版槑闃熷垪
+// Map<String, Object> args = new HashMap<>();
+// args.put("x-max-length-bytes",1024 * 1024);
+//// args.put("x-max-length",5000);
+// channel.queueDeclare(QUEUE_NAME, false, 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 -> {
+// });
+// }
}
}
--
Gitblit v1.8.0