TenantServiceAspect.java

@Aspect
@Component
public class TenantServiceAspect {

  @PersistenceContext public EntityManager entityManager;

  @Pointcut("execution(public * org.springframework.data.repository.Repository+.*(..))")
  void isRepository() {
    /* aspect */
  }

  @Pointcut(value = "isRepository()")
  void enableMultiTenancy() {
    /* aspect */
  }

  @Around("execution(public * *(..)) && enableMultiTenancy()")
  public Object aroundExecution(final ProceedingJoinPoint pjp) throws Throwable {
    if (!NoMultiTenancyConfiguration.doesTargetClassInterfaceHasNoMultiTenancyAnnotation(pjp.getTarget())) {
      if(!TenantAssistance.resolveCurrentUser().equals("admin")){
        final Session session = this.entityManager.unwrap(Session.class);
        final Filter filter =
                session
                        .enableFilter(TENANT_FILTER_NAME)
                        .setParameter(
                                TENANT_FILTER_ARGUMENT_NAME, TenantAssistance.resolveCurrentTenantIdentifier());
        filter.validate();
        if (Objects.isNull(session.getEnabledFilter(TENANT_FILTER_NAME))) {
          throw new UnknownTenantException("Hibernate filter is not enabled");
        }
      }
    }
    return pjp.proceed();
  }
}