package cn.flightfeather.supervision.common.utils;
|
|
import cn.flightfeather.supervision.common.executor.BgTaskStatus;
|
import cn.flightfeather.supervision.socket.WebSocketMessage;
|
import cn.flightfeather.supervision.socket.WebSocketMessageUtil;
|
import cn.flightfeather.supervision.socket.WebSocketSenderHandler;
|
|
public class SendSocketMessageUtil {
|
|
/**
|
* 发送后台任务的socket消息
|
* @param bgTaskStatus 消息的内容
|
*/
|
public static void sendBgTaskMessage(BgTaskStatus bgTaskStatus) {
|
WebSocketMessage webSocketMessage = new WebSocketMessage(Constant.SocketMessageType.BG_TASK.getValue(),
|
bgTaskStatus);
|
String message = WebSocketMessageUtil.encodeMessage(webSocketMessage);
|
WebSocketSenderHandler.getInstance().broadcast(message);
|
}
|
}
|
