apache / apache/rocketmq-spring
RocketMQListener support list covert error
- Dominant language
- Java
- Stars
- 2.3k
- Forks
- 943
- PR merge metrics
- No merged PRs in 30d
Description
```java
package com.xxx.application.handle;
import com.xxx.application.log.TaskLogDetailEvent;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author
* @Date 2021/11/18 1:56 下午
* @Version 1.0
*/
@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.group}", topic = "tasklogdetailevent-test", consumeMode = ConsumeMode.ORDERLY)
public class TestLogListener implements RocketMQListener> {
@Override
public void onMessage(List taskLogDetailEvents) {
// String s = JSON.toJSONString(taskLogDetailEvents);
// taskLogDetailEvents = JSON.parseArray(s, TaskLogDetailEvent.class);
System.out.println(1111);
}
}
```
2.3.4.RELEASE DefaultRocketMQListenerContainer getMessageType covert error
Caused by: java.lang.ClassCastException: sun.reflect.generics.reflectiveObjects.ParameterizedTypeImpl cannot be cast to java.lang.Class
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.getMessageType(DefaultRocketMQListenerContainer.java:381)
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.afterPropertiesSet(DefaultRocketMQListenerContainer.java:277)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1853)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1790)
... 21 common frames omitted
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.