You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/11/22 06:53:49 UTC
[GitHub] [rocketmq-spring] moses-keqi opened a new issue #407: RocketMQListener support list covert error
moses-keqi opened a new issue #407:
URL: https://github.com/apache/rocketmq-spring/issues/407
`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<List<TaskLogDetailEvent>> {
@Override
public void onMessage(List<TaskLogDetailEvent> 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
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] moses-keqi edited a comment on issue #407: RocketMQListener support list covert error
Posted by GitBox <gi...@apache.org>.
moses-keqi edited a comment on issue #407:
URL: https://github.com/apache/rocketmq-spring/issues/407#issuecomment-983227000
与spring-cloud-dependencies-parent rocketmq-spring-boot-starter 冲突
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-spring] moses-keqi commented on issue #407: RocketMQListener support list covert error
Posted by GitBox <gi...@apache.org>.
moses-keqi commented on issue #407:
URL: https://github.com/apache/rocketmq-spring/issues/407#issuecomment-983227000
最后发现原来引入maven 自身除了问题
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org