From ea073afc6b4bc758990ac60f5e33254d1143272c Mon Sep 17 00:00:00 2001
From: wang <3597712270@qq.com>
Date: 星期二, 26 三月 2024 13:58:03 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes
---
UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java | 46 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 46 insertions(+), 0 deletions(-)
diff --git a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
new file mode 100644
index 0000000..75c2e16
--- /dev/null
+++ b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
@@ -0,0 +1,46 @@
+package com.mes.service;
+
+import com.mes.common.RabbitMQUtils;
+
+public class ModuleB {
+ private final static String QUEUE_NAME = "hangzhou2";
+
+ public static void main(String[] argv) throws Exception {
+
+
+
+ RabbitMQUtils receiver = new RabbitMQUtils();
+
+ try {
+
+ receiver.consumeMessageById("2",QUEUE_NAME);
+ // String receivedMessage = receiver.consumeSelectedMessage(1,QUEUE_NAME);
+// String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));
+ // 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