StompPayload.java
742 Bytes
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
package com.huaheng.pc.stompwebsocket.domain;
import lombok.Data;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
/**
* @author
*/
@Data
public class StompPayload<T> implements Serializable {
//接收方的LoginName
private List<String> sendTo;
// QoS0:At most once,至多一次。
// QoS1:At least once,至少一次。
private int qos = 0;
//默认只发一次
//数据包
private T data;
public boolean isQos0() {
return qos == 0;
}
public boolean isQos1() {
return qos == 1;
}
public void addUser(String user){
if(sendTo == null){
sendTo = new ArrayList<>();
}
sendTo.add(user);
}
}