ActiveMQJmxMonitorTest.java 文件源码

@Override
public void onEvent(ActiveMQJmxMonitor.NotificationType notificationType, ActiveMQJmxMonitor.State state, ObjectInstance objectInstance) {
    if (notificationType == ActiveMQJmxMonitor.NotificationType.SLOW_CONSUMER) {
        if (state == ActiveMQJmxMonitor.State.START) slowConsumers++;
        else if (state == ActiveMQJmxMonitor.State.END) slowConsumers--;
    } else if (notificationType == ActiveMQJmxMonitor.NotificationType.PRODUCER_BLOCKED) {
        if (state == ActiveMQJmxMonitor.State.START) blockedProducers++;
        else if (state == ActiveMQJmxMonitor.State.END) blockedProducers--;
    }
}