如何被通知ApacheActiveMQ代理创建/关闭连接？

1. 使用ActiveMQ的事件监听器机制，可以在连接创建和关闭时获取对应的事件。例如，可以实现自定义监听器并继承ActiveMQ提供的TransportListener类。具体代码示例如下：

import org.apache.activemq.transport.TransportListener; import org.slf4j.Logger; import org.slf4j.LoggerFactory;

public class CustomTransportListener implements TransportListener {

private static final Logger LOGGER = LoggerFactory.getLogger(CustomTransportListener.class);

@Override
public void onCommand(Object command) {
    // 消息处理
}

@Override
public void onException(IOException error) {
    LOGGER.error("Transport encountered an exception", error);
}

// 连接创建事件
@Override
public void transportInterupted() {
    LOGGER.info("Transport interrupted");
}

// 连接关闭事件
@Override
public void transportResumed() {
    LOGGER.info("Transport resumed");
}

}

2. 在ActiveMQ的配置文件中开启相关设置。

<transportConnector name="openwire" uri="tcp://localhost:61616?transport.trace=true" transportListener="com.example.CustomTransportListener"/>

上述代码将会在ActiveMQ代理上监听连接创建和关闭事件，并打印相应信息。