From c19dc3fb9afc4dfee063225cc38b0a2d5294c5a7 Mon Sep 17 00:00:00 2001 From: wuyouming666 <2265557248@qq.com> Date: 星期一, 01 四月 2024 16:56:39 +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