private void processResponseCommand(ChannelHandlerContext ctx, Cmq.CMQProto cmd) 这个方法中的if返回code是306的话,直接return了,那我这次发送就没有结果了, if (cmd.getResult() == CONNECTION_NOT_AUTHED) { this.closeChannel(ctx.channel()); return; } 应该要重试的吧
private void processResponseCommand(ChannelHandlerContext ctx, Cmq.CMQProto cmd)
这个方法中的if返回code是306的话,直接return了,那我这次发送就没有结果了,
if (cmd.getResult() == CONNECTION_NOT_AUTHED) { this.closeChannel(ctx.channel()); return; }
应该要重试的吧