帮我写一个ActiveMQ 使用demo

以下是一个简单的ActiveMQ使用demo，包括如何创建连接、创建队列、发送和接收消息：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;

public class ActiveMQDemo {

  public static void main(String[] args) throws JMSException {
    // 创建连接工厂
    ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    // 创建连接
    Connection connection = factory.createConnection();
    // 启动连接
    connection.start();
    // 创建会话
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    // 创建目标，即队列
    Destination destination = session.createQueue("test.queue");
    // 创建生产者
    MessageProducer producer = session.createProducer(destination);
    // 发送消息
    TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
    producer.send(message);
    // 创建消费者
    MessageConsumer consumer = session.createConsumer(destination);
    // 接收消息
    Message receivedMessage = consumer.receive();
    if (receivedMessage instanceof TextMessage) {
      TextMessage receivedTextMessage = (TextMessage) receivedMessage;
      System.out.println("Received message: " + receivedTextMessage.getText());
    }
    // 关闭连接
    connection.close();
  }

}

此代码演示了如何使用ActiveMQ连接到本地ActiveMQ代理，创建一个名为“test.queue”的队列，将“Hello，ActiveMQ！”消息发送到该队列，然后接收该消息。您需要将“tcp：//localhost：61616”替换为您的ActiveMQ代理的地址。