Use the pulsar and spring aop ,the aop failed

[kevinWangSheng]

Search before asking

• I searched in the issues and found nothing similar.

Read release policy

• I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.

Version

windwos 10 64x
jdk8
pulsar:2.1

Minimal reproduce step

does it support spring aop ?

What did you expect to see?

i want to go to the aspcet

@pointcut("@Within(com.ak.cepf.mybatis.aspect.IgnoreTenant) ||@annotation(com.ak.cepf.mybatis.aspect.IgnoreTenant)")
public void pointcut() {
}

@Around("pointcut()")
public Object around(ProceedingJoinPoint point) throws Throwable {
    Object var9;
    try {
        Class<?> targetClass = point.getTarget().getClass();
        IgnoreTenant classIgnoreTenant = (IgnoreTenant)targetClass.getAnnotation(IgnoreTenant.class);
        MethodSignature signature = (MethodSignature)point.getSignature();
        Method method = signature.getMethod();
        IgnoreTenant methodIgnoreTenant = (IgnoreTenant)method.getAnnotation(IgnoreTenant.class);
        boolean isClassAnnotated = AnnotationUtils.isAnnotationDeclaredLocally(IgnoreTenant.class, targetClass);
        boolean isMethodAnnotated = Objects.nonNull(methodIgnoreTenant);
        if (isClassAnnotated) {
            MybatisTenantContext.set(classIgnoreTenant.isIgnore());
        }

        if (isMethodAnnotated) {
            MybatisTenantContext.set(methodIgnoreTenant.isIgnore());
        }

        var9 = point.proceed();
    } finally {
        MybatisTenantContext.clear();
    }

    return var9;
}


and config like that :


@PulsarConsumer(topic = "cepf_listing_change",
        subscriptionName = "cepf_statistics",
        serverName = "amsPulsar",
        clazz = byte[].class,
        initialPosition = SubscriptionInitialPosition.Latest,
        serialization = Serialization.BYTE,
        deadLetterTopic = "cepf_listing_change-dlq",
        maxRedeliverCount = 3
)
// 不走租户
@IgnoreTenant
// todo 消费供货价改变消息
public void consumeSupplyPriceChangeMessage(PulsarMessage<byte[]> message){
    try {
        log.info("[orderItemPriceChange] messageId:{},message{}",message.getMessageId(),message);
        MessageDTO messageDto = JSONObject.parseObject(message.getValue(), MessageDTO.class);
        if(ObjectUtil.isEmpty(messageDto)){
            return;
        }
        supplyPriceChangeRepairService.repairItemsCommonPriceAmount(messageDto);
    } catch (Exception e) {
        // 放到死信队列进行重试
        log.warn("[orderItemPriceChange] 消费失败，进行重试:{}", JSON.toJSONString(message));
        e.printStackTrace();
        throw e;
    }
}

the PulsarConsumer is depend on pulsar

What did you see instead?

I debug and don't see go to the code:
@pointcut("@Within(com.ak.cepf.mybatis.aspect.IgnoreTenant) ||@annotation(com.ak.cepf.mybatis.aspect.IgnoreTenant)")
public void pointcut() {
}

@Around("pointcut()")
public Object around(ProceedingJoinPoint point) throws Throwable {
    Object var9;
    try {
        Class<?> targetClass = point.getTarget().getClass();
        IgnoreTenant classIgnoreTenant = (IgnoreTenant)targetClass.getAnnotation(IgnoreTenant.class);
        MethodSignature signature = (MethodSignature)point.getSignature();
        Method method = signature.getMethod();
        IgnoreTenant methodIgnoreTenant = (IgnoreTenant)method.getAnnotation(IgnoreTenant.class);
        boolean isClassAnnotated = AnnotationUtils.isAnnotationDeclaredLocally(IgnoreTenant.class, targetClass);
        boolean isMethodAnnotated = Objects.nonNull(methodIgnoreTenant);
        if (isClassAnnotated) {
            MybatisTenantContext.set(classIgnoreTenant.isIgnore());
        }

        if (isMethodAnnotated) {
            MybatisTenantContext.set(methodIgnoreTenant.isIgnore());
        }

        var9 = point.proceed();
    } finally {
        MybatisTenantContext.clear();
    }

    return var9;
}

Anything else?

i guess it doesn't support spring aop ?
i know it's threapool is not registry to spring?
so i doesn't support it?
i want to know why.

Are you willing to submit a PR?

• I'm willing to submit a PR!

[lhotari]

I migrated this to a GitHub Discussion since this is not a bug in Apache Pulsar.

[kevinWangSheng]

Is pulsar doesn't support the thread registry to spring?Does anyone know that? please help me, I would appreciate that;