更新

严智鑫

2024-04-02 532e9a9b241f736fe0ed6ebb2bbd7ed00f9955ce

 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";



@@ -12,8 +14,12 @@
        RabbitMQUtils receiver = new RabbitMQUtils();



        try {

            String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));

            System.out.println("Received message: " + receivedMessage);



            //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();

        }