ActiveMQ:如何将旧邮件出列？

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;

public class RemoveOldMessages {
    public static void main(String[] args) throws Exception {
        // 初始化 JNDI 上下文
        InitialContext context = new InitialContext();

        // 获取连接工厂和队列
        ConnectionFactory factory = (ConnectionFactory) context.lookup("ConnectionFactory");
        Queue queue = (Queue) context.lookup("queue/myQueue");

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

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

        // 循环接收消息，直到队列为空
        while (true) {
            TextMessage message = (TextMessage) consumer.receive(1000);
            if (message == null) {
                break;
            }

            // 处理消息
            System.out.println("Received message: " + message.getText());

            // 确认消息已被接收
            message.acknowledge();

            // 移除消息
            consumer.close();
            session.close();
            connection.close();
        }
    }
}