package com.mes.service;

import com.mes.common.RabbitMQUtils;

import java.util.List;

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