RocketMQMessageListenerBeanPostProcessor implements SmartLifecycle start()
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Aptitud para principiantes
- 45/100
- Tipo de issue
- Error
- Claridad
- Bastante claro
- Estado de actividad
- Tranquilo
- Stack tecnológico
- java, spring, spring-boot
- Área
- backend, distributed-systems
Línea de trabajo
Comienza con RocketMQMessageListenerBeanPostProcessor, especialmente con postProcessAfterInitialization() y start(), y reproduce el orden registrado usando únicamente Spring Boot 2.7.18 y usando las dependencias de Spring Cloud Alibaba indicadas. Sigue las callbacks del ciclo de vida y las llamadas al registrar; se considera terminado cuando los contenedores de listeners se registran antes de que se ejecute startContainer() en ambas configuraciones.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
@Override
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
Class<?> targetClass = AopUtils.getTargetClass(bean);
RocketMQMessageListener ann = targetClass.getAnnotation(RocketMQMessageListener.class);
if (ann != null) {
RocketMQMessageListener enhance = enhance(targetClass, ann);
if (listenerContainerRegistrar != null) {
log.warn("=== 111 ====");
listenerContainerRegistrar.registerContainer(beanName, bean, enhance);
}
}
return bean;
}
@Override
public int getPhase() {
return Integer.MAX_VALUE - 2000;
}
@Override
public void start() {
if (!isRunning()) {
this.setRunning(true);
log.warn("=== 222 ====");
listenerContainerRegistrar.startContainer();
}
}
1、单独使用spring-boot 2.7.18 registerContainer start 顺序正确可正常使用。
执行顺序
=== 111 ==== 先执行
=== 222 ==== 后执行
registerContainer 注册正常。
start 正常。
2、主要依赖如下
spring-cloud 2021.0.6
spring-cloud-starter-alibaba 2021.0.6.1
spring-boot 2.7.18
执行顺序
=== 222 ==== 先执行
=== 111 ==== 后执行
registerContainer 注册正常。
start 未能正常执行。
- Lenguaje dominante
- Java
- Estrellas
- 2.3k
- Forks
- 941
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Sin guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/rocketmq-spring
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operationsPosiblemente ocupada @wang-jiahua la tomó hace 56 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100
apache/rocketmq-spring#780 · 3 comentarios ·
-
编译报错Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
apache/rocketmq-spring#692 · 1 comentario ·
-
消费者注册时候对nameserver取值有点问题Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
apache/rocketmq-spring#678 · 2 comentarios ·
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 82/100
apache/rocketmq-spring#670 · 1 comentario ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 62/100
apache/rocketmq-spring#609 · 3 comentarios ·
Todos los issues de apache/rocketmq-spring
Issues similares
-
area:core bug priority:p2
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
aomarai/minecraft-mcp#247 ·
Los mantenedores suelen responder en 1 día
-
help wanted
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
antonyrag/ragleap-core#1062 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 66/100
Vakore/ZappierGames#232 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 83/100
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 64/100
constellation-app/constellation#2588 ·