class BrokerInterceptor implements Interceptor {

    @Override
    public void notifyClientConnected(final MqttConnectMessage msg) {
        for (final InterceptHandler handler : this.handlers.get(InterceptConnectMessage.class)) {
            LOG.debug("Sending MQTT CONNECT message to interceptor. CId={}, interceptorId={}",
                    msg.payload().clientIdentifier(), handler.getID());
            executor.execute(() -> handler.onConnect(new InterceptConnectMessage(msg)));
        }
    }

    private  BrokerInterceptor(int poolSize, List<InterceptHandler> handlers);
      BrokerInterceptor(List<InterceptHandler> handlers);
      BrokerInterceptor(IConfig props, List<InterceptHandler> handlers);

}