rocketmq-spring

rocketmq-spring copied to clipboard

[ISSUE #424] Fix NPE when using ExtRocketMQTemplateConfiguration regi…

4

Fix NPE when using ExtRocketMQTemplateConfiguration register RocketMQTemplate

ljznb666

## What is the purpose of the change [!479](https://github.com/apache/rocketmq-spring/issues/479) ## Brief changelog 1. ListenerContainerConfiguration remove SmartInitializingSingleton interface 2. add RocketMQMessageListenerBeanPostProcessor to registerContainer ## Verifying this change Follow this checklist to...

kosmosr

ListenerContainerConfiguration should not depend on concrete class StandardEnvironment

2

Interface `ConfigurableEnvironment` should be enough for bellow code: code link: https://github.com/apache/rocketmq-spring/blob/21097621e092a618709f8220ee2ccd0acbaa3af0/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ListenerContainerConfiguration.java#L55 My application has a customized `ConfigurableEnvironment` implementation, but it cannot startup correctly. Below is a demo code fragment: ```java...

fishautumn

Allow programmatic modify @RocketMQMessageListener annotation properties

3

**FEATURE REQUEST** 1. Please describe the feature you are requesting. In a jvm process, I can define different @RocketMQMessageListener annotations on the prototype bean and programmatically set the different annotation...

kosmosr

## What is the purpose of the change It's better to depend on interface than on a concrete class. see issue #477 for detail. ## Brief changelog change StandardEnvironment to...

fishautumn

The rocketMQTemplate does not exist TransactionListener

8

1.环境 ``` org.springframework.boot spring-boot-starter-parent 2.4.2 org.apache.rocketmq rocketmq-spring-boot-starter 2.2.1 ``` 2.我做了什么 简单实现了RocketMQLocalTransactionListener接口的两个方法，都是返回`RocketMQLocalTransactionState.COMMIT` ``` @Service @RocketMQTransactionListener public class OrderServiceImpl4Listener implements RocketMQLocalTransactionListener { } ``` 在Controller中发送了一个事务消息 ``` @Resource private RocketMQTemplate rocketMQTemplate; @RequestMapping("/test2") public...

kiritokun07

Heap memory leak caused OOM

11

**BUG REPORT** 1. Please describe the issue you observed: Heap memory leak caused OOM. - What did you do (The steps to reproduce)? ``` @Slf4j @Component @RocketMQMessageListener(topic = "${rocketmq.consumer.topic}" ,...

kahle23

RocketMQMessageConverter not surport add ProtobufMessageConverter

2

The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **BUG REPORT** 1. Please describe the issue you...

fattyliu

batch sync produce instead of sync produce got response code 13

6

**BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? When I produce a single message using org.apache.rocketmq.spring.core.RocketMQTemplate#syncSend(java.lang.String, org.springframework.messaging.Message) to a topic,...

GeorgeLyu1992

Is it needed to separate producer and consumer in RocketMQAutoConfiguration

7

**FEATURE REQUEST**  `RocketMQAutoConfiguration` automatically imports `ListenerContainerConfiguration` and will start all consumers' listening threads after springboot starts. But in a normal project, I actually need to separate the producer and...

deanisty