Bagaimana untuk melaksanakan komunikasi tak segerak menggunakan baris gilir mesej di Jawa?

import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.Connection;
import javax.jms.Session;
import javax.jms.Queue;
import javax.jms.MessageProducer;
import javax.jms.TextMessage;

public class AsyncCommunicationExample {
    public static void main(String[] args) {
        // 创建连接工厂
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");

        try {
            // 创建连接和会话
            Connection connection = factory.createConnection();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // 创建一个名为hello的队列
            Queue queue = session.createQueue("hello");

            // 创建消息生产者
            MessageProducer producer = session.createProducer(queue);

            // 创建消息并发送
            TextMessage message = session.createTextMessage();
            message.setText("Hello, world!");
            producer.send(message);

            // 关闭连接
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.Connection;
import javax.jms.Session;
import javax.jms.Queue;
import javax.jms.MessageConsumer;
import javax.jms.Message;

public class AsyncCommunicationExample {
    public static void main(String[] args) {
        // 创建连接工厂
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");

        try {
            // 创建连接和会话
            Connection connection = factory.createConnection();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // 创建一个名为hello的队列
            Queue queue = session.createQueue("hello");

            // 创建消息消费者
            MessageConsumer consumer = session.createConsumer(queue);

            // 监听消息并处理
            consumer.setMessageListener(message -> {
                try {
                    System.out.println("Received message: " + ((TextMessage) message).getText());
                } catch (Exception e) {
                    e.printStackTrace();
                }
            });

            // 启动连接
            connection.start();

            // 等待消息
            Thread.sleep(10000);

            // 关闭连接
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}