如何从ActiveMQ推送消息的Java代码

ChatGPT的回答仅作参考：

以下是一个简单的Java代码示例，用于从ActiveMQ推送消息：

```java
import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

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

        // 创建连接
        Connection connection = connectionFactory.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);

        // 关闭连接
        connection.close();
    }
}
```

在此示例中，我们使用ActiveMQConnectionFactory创建连接工厂，并使用它创建连接。然后，我们创建会话和目的地，并使用它们创建生产者。最后，我们创建消息并使用生产者发送它。最后，我们关闭连接。