From 82e0ee9e39953af0b39e5471eb6a9be2d442fb7d Mon Sep 17 00:00:00 2001 From: wuyouming666 <2265557248@qq.com> Date: 星期三, 27 三月 2024 17:01:54 +0800 Subject: [PATCH] 更新下片逻辑 --- UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java | 9 ++++++--- 1 files changed, 6 insertions(+), 3 deletions(-) diff --git a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java index 75c2e16..2cd57e4 100644 --- a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java +++ b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java @@ -2,6 +2,8 @@ import com.mes.common.RabbitMQUtils; +import java.util.List; + public class ModuleB { private final static String QUEUE_NAME = "hangzhou2"; @@ -13,10 +15,11 @@ try { - receiver.consumeMessageById("2",QUEUE_NAME); + //receiver.consumeMessageById("5",QUEUE_NAME); + // String receivedMessage = receiver.consumeSelectedMessage(1,QUEUE_NAME); -// String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false)); - // System.out.println("Received message: " + receivedMessage); + List<String> receivedMessage = receiver.browseMessages(QUEUE_NAME); + System.out.println("Received message: " + receivedMessage); } catch (Exception e) { e.printStackTrace(); } -- Gitblit v1.8.0