Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: consume type compatible with protocol #387

Merged
merged 1 commit into from
Jan 15, 2020

Conversation

ahjdzx
Copy link
Contributor

@ahjdzx ahjdzx commented Jan 14, 2020

通过 mqadmin consumerStatus 查看消费者状态时,命令执行失败。

$ NAMESRV_ADDR=localhost:9876 sh bin/mqadmin consumerStatus -g testGroup                                                                                                                                   (rocketmq-all-4.5.2*) 13:37:07
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
001  172.17.200.98@DEFAULT                    V4_5_2               1578980233054/172.17.200.98@DEFAULT
org.apache.rocketmq.tools.command.SubCommandException: ConsumerStatusSubCommand command failed
        at org.apache.rocketmq.tools.command.consumer.ConsumerStatusSubCommand.execute(ConsumerStatusSubCommand.java:134)
        at org.apache.rocketmq.tools.command.MQAdminStartup.main0(MQAdminStartup.java:139)
        at org.apache.rocketmq.tools.command.MQAdminStartup.main(MQAdminStartup.java:90)
Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.rocketmq.common.protocol.heartbeat.ConsumeType.push
        at java.lang.Enum.valueOf(Enum.java:238)
        at org.apache.rocketmq.common.protocol.heartbeat.ConsumeType.valueOf(ConsumeType.java:23)
        at org.apache.rocketmq.common.protocol.body.ConsumerRunningInfo.analyzeSubscription(ConsumerRunningInfo.java:58)
        at org.apache.rocketmq.tools.command.consumer.ConsumerStatusSubCommand.execute(ConsumerStatusSubCommand.java:105)
        ... 2 more

修改 ConsumeType 常量值后解决。

@codecov-io
Copy link

Codecov Report

Merging #387 into native will not change coverage.
The diff coverage is n/a.

Impacted file tree graph

@@           Coverage Diff           @@
##           native     #387   +/-   ##
=======================================
  Coverage   25.37%   25.37%           
=======================================
  Files          47       47           
  Lines        5470     5470           
=======================================
  Hits         1388     1388           
  Misses       3892     3892           
  Partials      190      190
Impacted Files Coverage Δ
consumer/consumer.go 18.84% <ø> (ø) ⬆️

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 145a42c...bc414b8. Read the comment docs.

@ShannonDing ShannonDing added the bug Something isn't working label Jan 14, 2020
@ShannonDing ShannonDing modified the milestones: 2.0.0-RC2, 2.0.0 Jan 14, 2020
@wenfengwang wenfengwang merged commit 27e707e into apache:native Jan 15, 2020
@ahjdzx ahjdzx deleted the fix_consume_type branch January 15, 2020 03:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants