@Component
@Order(Ordered.HIGHEST_PRECEDENCE)
public class InterceptRepositoryBeanPostProcessor implements BeanPostProcessor {
    public static final Logger logger = LoggerFactory.getLogger(InterceptRepositoryBeanPostProcessor.class);
    private final ApplicationContext context;
    private final MeterRegistry meterRegistry;
    @Autowired
    public InterceptRepositoryBeanPostProcessor(ApplicationContext context, MeterRegistry meterRegistry) {
        this.context = context;
        this.meterRegistry = meterRegistry;
        logger.info("Starting InterceptRepositoryBeanPostProcessor");
    }
    @Override
    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
        logger.info("post processing BEFORE initialization: {}", beanName);
        return bean;
    }
    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
        logger.info("post processing AFTER initialization: {}", beanName);
        // If the bean is annotated with @Repository, wrap it in a proxy
        if (bean.getClass().isAnnotationPresent(Repository.class)) {
            logger.info("CREATING proxy with RepositoryInvocationMetricsHandler for {}",
                        beanName);
            return createRepositoryProxy(bean);
        }
        return bean;
    }
    /**
     * Create a proxy by wrapping the Repository implementation in a RepositoryInvocationMetricsHandler
     *
     * @param bean The Repository to create a proxy for
     * @return A new  proxy - RepositoryInvocationMetricsHandler
     */
    private Object createRepositoryProxy(Object bean) {
        logger.info("Creating repository proxy for bean: {}", bean.getClass().getSimpleName());
        Class<?> target = bean.getClass();
        ClassLoader classLoader = target.getClassLoader();
        Class<?>[] interfaces = target.getInterfaces();
        return Proxy.newProxyInstance(classLoader,
                                      interfaces,
                                      new RepositoryInvocationMetricsHandler(target, context, meterRegistry));
    }
}

@Component
@Aspect
public class RepositoryInvocationMetricsAspect {
  private final ApplicationContext context;
  private final MeterRegistry meterRegistry;
  public RepositoryInvocationMetricsAspect(ApplicationContext ctx, MeterRegistry meterRegistry) {
    this.context=context;
    this.meterRegistry=meterRegistry;
  }
  @Pointcut(@within(@org.springframework.stereotype.Repository))
  public void repositories() {}
  @Around("repositories()")
  public Object recordMetrics(ProceedingJoinPoint pjp) {
    try {
      // start metrics
      return pjp.proceed();
    } finally {
      //end metrics
    }
  }
}