1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
| package com.fastbee.mqtt.model;
|
| import io.netty.handler.codec.mqtt.MqttQoS;
| import lombok.AllArgsConstructor;
| import lombok.Data;
| import lombok.NoArgsConstructor;
|
| /**
| * @author gsb
| * @date 2022/10/7 19:04
| */
| @Data
| @NoArgsConstructor
| @AllArgsConstructor
| public class ClientMessage {
|
| /*共享主题客户端id，不为空则指定客户端发送*/
| private String sharedClientId;
| /*客户端id*/
| private String clientId;
| /*消息质量*/
| private MqttQoS qos;
| /*topic*/
| private String topicName;
| /*是否保留消息*/
| private boolean retain;
| /*数据*/
| private byte[] payload;
|
| private int messageId;
| /*是否是遗嘱消息*/
| private boolean willFlag;
| /*是否是dup消息*/
| private boolean dup;
|
|
| public static ClientMessage of(MqttQoS qos,String topicName,boolean retain, byte[] payload){
| return new ClientMessage(null,null,qos,topicName,retain,payload,0,false,false);
| }
|
| public static ClientMessage of(String clientId,MqttQoS qos,String topicName,boolean retain){
| return new ClientMessage(null,clientId,qos,topicName,retain,null,0,false,false);
| }
|
| }
|
|
