Java 类io.vertx.core.spi.metrics.EventBusMetrics 实例源码

public DispatchingEventBusMetrics(List<? extends EventBusMetrics> delegates) {
    super(delegates);
}

@Override
public Map<EventBusMetrics, ?> handlerRegistered(String address, String repliedAddress) {
    return dispatchWithResult(m -> m.handlerRegistered(address, repliedAddress));
}

@Override
public void handlerUnregistered(Map<EventBusMetrics, ?> handler) {
    unmap(handler, (m, h) -> m.handlerUnregistered(h));
}

@Override
public void scheduleMessage(Map<EventBusMetrics, ?> handler, boolean local) {
    unmap(handler, (m, h) -> m.scheduleMessage(h, local));
}

@Override
public void beginHandleMessage(Map<EventBusMetrics, ?> handler, boolean local) {
    unmap(handler, (m, h) -> m.beginHandleMessage(h, local));
}

@Override
public void endHandleMessage(Map<EventBusMetrics, ?> handler, Throwable failure) {
    unmap(handler, (m, h) -> m.endHandleMessage(h, failure));
}

@Override
default EventBusMetrics createMetrics(EventBus eventBus) {
    return DummyVertxMetrics.DummyEventBusMetrics.INSTANCE;
}

@Override
public EventBusMetrics<?> createMetrics(EventBus eventBus) {
    return createSubMetrics(v -> v.createMetrics(eventBus),
            d -> new DispatchingEventBusMetrics(d));
}

@Override
public EventBusMetrics createMetrics(EventBus eventBus) {
    return new EventBusMetricsImpl(counterService, gaugeService, properties.getEventBus());
}

@Override
public EventBusMetrics createMetrics(EventBus eventBus) {
  EventBusMetrics supplier = (EventBusMetrics) metricSuppliers.get(EVENT_BUS);
  return supplier != null ? supplier : super.createMetrics(eventBus);
}

@Override
public EventBusMetrics createMetrics(EventBus eventBus) {
  return new EventBusMetricsImpl(this, nameOf("eventbus"), options);
}