Java 类io.netty.handler.codec.mqtt.MqttDecoder.DecoderState 实例源码

public MqttDecoder(int maxBytesInMessage) {
    super(DecoderState.READ_FIXED_HEADER);
    this.maxBytesInMessage = maxBytesInMessage;
}

private MqttMessage invalidMessage(Throwable cause) {
    checkpoint(DecoderState.BAD_MESSAGE);
    return MqttMessageFactory.newInvalidMessage(cause);
}

public MqttDecoder(int maxBytesInMessage) {
    super(DecoderState.READ_FIXED_HEADER);
    this.maxBytesInMessage = maxBytesInMessage;
}

private MqttMessage invalidMessage(Throwable cause) {
  checkpoint(DecoderState.BAD_MESSAGE);
  return MqttMessageFactory.newInvalidMessage(cause);
}

public MqttDecoder(int maxBytesInMessage) {
    super(DecoderState.READ_FIXED_HEADER);
    this.maxBytesInMessage = maxBytesInMessage;
}

private MqttMessage invalidMessage(Throwable cause) {
    checkpoint(DecoderState.BAD_MESSAGE);
    return MqttMessageFactory.newInvalidMessage(cause);
}