ActiveMQ broker关闭时使用的传输侦听器

import org.apache.activemq.transport.TransportListener;

public class MyTransportListener implements TransportListener {

    @Override
    public void transportResumed() {
        // 连接已恢复时执行的操作
    }

    @Override
    public void transportInterupted() {
        // 连接中断时执行的操作
    }

    @Override
    public void onException(IOException error) {
        // 发生异常时执行的操作
    }

    @Override
    public void connectionEstablished() {
        // 连接建立时执行的操作
    }
}

import org.apache.activemq.ActiveMQConnectionFactory;

public class CloseBrokerExample {

    public static void main(String[] args) {
        try {
            // 创建连接工厂
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            
            // 创建连接
            Connection connection = factory.createConnection();
            
            // 注册传输侦听器
            connection.setTransportListener(new MyTransportListener());
            
            // 关闭连接
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}