wms / hhwms · Files

package com.huaheng.pc.stompwebsocket.domain;

import lombok.Data;

import java.io.Serializable;

import java.util.ArrayList;

import java.util.List;

@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);
    }

}