事务消息demo

[HackerRookie]

业务代码 是不是要写在 executeLocalTransaction/checkLocalTransaction 里面？能否提供具体的demo

AbstractMQTransactionProducer beanObj = AbstractMQTransactionProducer.class.cast(transactionProducer.getValue()); MQTransactionProducer anno = beanObj.getClass().getAnnotation(MQTransactionProducer.class);

            TransactionMQProducer producer = new TransactionMQProducer(environment.resolvePlaceholders(anno.producerGroup()));
            producer.setNamesrvAddr(mqProperties.getNameServerAddress());
            producer.setExecutorService(executorService);
            producer.setTransactionListener(beanObj);
            producer.start();
            beanObj.setProducer(producer);

这个producer和beanObje 循环引用 会不会释放不掉的