稍稍优化下消息类型解析方法，抽象推拉消费者中的公共代码

maihaoche / rocketmq-spring-boot-starter

Spring Boot starter for RocketMQ

Apache License 2.0

287 stars 147 forks source link

Closed jaychang9 closed 7 years ago

jaychang9 commented 7 years ago

将AbstractMQPullConsumer及AbstractPushConsumer公共代码抽象至AbstractMQConsumer

解析消息类型的方法：gson.fromJson(new String(message.getBody()), type);返回的类型无需用一个Object data引用接收，再转为(T)data，直接返回即可

getMessageTypef方法增加断言，Type参数个数必须是1个

将rocketmq版本升级为4.1.0-incubating

suclogger commented 7 years ago

感谢贡献代码~ 4.1.0-incubating 能否向下兼容如 4.0.0-incubating 版本的rocketmq实例？

jaychang9 commented 7 years ago

没具体测试过，目前使用情况来看，好像没有什么问题，应该是可以完美兼容的