package chat.server.moquette.message; import io.netty.util.internal.ObjectUtil; public class MqttFixedHeader { private final MqttMessageType messageType; private final boolean isDup; private final MqttQoS qosLevel; private final boolean isRetain; private final int remainingLength; public MqttFixedHeader(MqttMessageType messageType, boolean isDup, MqttQoS qosLevel, boolean isRetain, int remainingLength) { this.messageType = ObjectUtil.checkNotNull(messageType, "messageType"); this.isDup = isDup; this.qosLevel = ObjectUtil.checkNotNull(qosLevel, "qosLevel"); this.isRetain = isRetain; this.remainingLength = remainingLength; } public MqttMessageType messageType() { return messageType; } public boolean isDup() { return isDup; } public MqttQoS qosLevel() { return qosLevel; } public boolean isRetain() { return isRetain; } public int remainingLength() { return remainingLength; } @Override public String toString() { StringBuilder result = new StringBuilder(); result.append(this.getClass().getSimpleName()); result.append('['); result.append("messageType=").append(messageType); result.append(", isDup=").append(isDup); result.append(", qosLevel=").append(qosLevel); result.append(", isRetain=").append(isRetain); result.append(", remainingLength=").append(remainingLength); result.append(']'); return result.toString(); } }