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
25 public final class MqttTopicSubscription {
26
27 private final String topicFilter;
28 private final MqttSubscriptionOption option;
29
30 public MqttTopicSubscription(String topicFilter, MqttQoS qualityOfService) {
31 this.topicFilter = topicFilter;
32 this.option = MqttSubscriptionOption.onlyFromQos(qualityOfService);
33 }
34
35 public MqttTopicSubscription(String topicFilter, MqttSubscriptionOption option) {
36 this.topicFilter = topicFilter;
37 this.option = option;
38 }
39
40
41
42
43 @Deprecated
44 public String topicName() {
45 return topicFilter;
46 }
47
48 public String topicFilter() {
49 return topicFilter;
50 }
51
52 public MqttQoS qualityOfService() {
53 return option.qos();
54 }
55
56 public MqttSubscriptionOption option() {
57 return option;
58 }
59
60 @Override
61 public String toString() {
62 return new StringBuilder(StringUtil.simpleClassName(this))
63 .append('[')
64 .append("topicFilter=").append(topicFilter)
65 .append(", option=").append(this.option)
66 .append(']')
67 .toString();
68 }
69 }