update 优化 sse工具类

dev
疯狂的狮子Li 1 year ago
parent 7875e6c88c
commit c2285c7a23

@ -26,7 +26,7 @@ public class SseMessageUtils {
* @param message * @param message
*/ */
public static void sendMessage(Long userId, String message) { public static void sendMessage(Long userId, String message) {
if (SSE_ENABLE) { if (!isEnable()) {
return; return;
} }
MANAGER.sendMessage(userId, message); MANAGER.sendMessage(userId, message);
@ -38,7 +38,7 @@ public class SseMessageUtils {
* @param message * @param message
*/ */
public static void sendMessage(String message) { public static void sendMessage(String message) {
if (SSE_ENABLE) { if (!isEnable()) {
return; return;
} }
MANAGER.sendMessage(message); MANAGER.sendMessage(message);
@ -50,7 +50,7 @@ public class SseMessageUtils {
* @param sseMessageDto SSE * @param sseMessageDto SSE
*/ */
public static void publishMessage(SseMessageDto sseMessageDto) { public static void publishMessage(SseMessageDto sseMessageDto) {
if (SSE_ENABLE) { if (!isEnable()) {
return; return;
} }
MANAGER.publishMessage(sseMessageDto); MANAGER.publishMessage(sseMessageDto);
@ -62,10 +62,17 @@ public class SseMessageUtils {
* @param message * @param message
*/ */
public static void publishAll(String message) { public static void publishAll(String message) {
if (SSE_ENABLE) { if (!isEnable()) {
return; return;
} }
MANAGER.publishAll(message); MANAGER.publishAll(message);
} }
/**
*
*/
public static Boolean isEnable() {
return SSE_ENABLE;
}
} }

Loading…
Cancel
Save