activemq ProducerCallback

ActiveMQ是一种常见的消息队列系统，可以用于实现异步通信和解耦系统组件。在ActiveMQ中，可以使用ProducerCallback来实现消息的发送和处理。

下面是一个示例代码，演示了如何使用ProducerCallback发送消息到ActiveMQ队列：

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

public class ProducerCallbackExample {
    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("myQueue");

        // 创建生产者
        MessageProducer producer = session.createProducer(destination);

        // 创建消息
        TextMessage message = session.createTextMessage("Hello, ActiveMQ!");

        // 发送消息
        producer.send(message, new AsyncCallback() {
            @Override
            public void onSuccess() {
                System.out.println("消息发送成功");
            }

            @Override
            public void onException(JMSException e) {
                System.out.println("消息发送失败：" + e.getMessage());
            }
        });

        // 关闭资源
        producer.close();
        session.close();
        connection.close();
    }
}

在上面的代码中，我们首先创建了一个连接工厂，然后使用该连接工厂创建了一个连接。接着，我们创建了一个会话和一个队列，并使用会话创建了一个生产者。然后，我们创建了一个消息，并使用生产者发送该消息到队列中。在发送消息时，我们使用了ProducerCallback来处理发送结果，当消息发送成功时，会调用onSuccess方法，当消息发送失败时，会调用onException方法。

请注意，上述代码中的连接地址"tcp://localhost:61616"是ActiveMQ的默认地址，你需要根据你的实际情况进行修改。