1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package io.netty.handler.codec.mqtt;
18
19 import io.netty.util.internal.StringUtil;
20
21
22
23
24 public final class MqttMessageIdAndPropertiesVariableHeader extends MqttMessageIdVariableHeader {
25
26 private final MqttProperties properties;
27
28 public MqttMessageIdAndPropertiesVariableHeader(int messageId, MqttProperties properties) {
29 super(messageId);
30 if (messageId < 1 || messageId > 0xffff) {
31 throw new IllegalArgumentException("messageId: " + messageId + " (expected: 1 ~ 65535)");
32 }
33 this.properties = MqttProperties.withEmptyDefaults(properties);
34 }
35
36 public MqttProperties properties() {
37 return properties;
38 }
39
40 @Override
41 public String toString() {
42 return StringUtil.simpleClassName(this) + "[" +
43 "messageId=" + messageId() +
44 ", properties=" + properties +
45 ']';
46 }
47
48 @Override
49 MqttMessageIdAndPropertiesVariableHeader withDefaultEmptyProperties() {
50 return this;
51 }
52 }