| | |
| | | * @param message 要发送的消息内容 |
| | | */ |
| | | public static void sendMessage(Long userId, String message) { |
| | | if (SSE_ENABLE) { |
| | | if (!isEnable()) { |
| | | return; |
| | | } |
| | | MANAGER.sendMessage(userId, message); |
| | |
| | | * @param message 要发送的消息内容 |
| | | */ |
| | | public static void sendMessage(String message) { |
| | | if (SSE_ENABLE) { |
| | | if (!isEnable()) { |
| | | return; |
| | | } |
| | | MANAGER.sendMessage(message); |
| | |
| | | * @param sseMessageDto 要发布的SSE消息对象 |
| | | */ |
| | | public static void publishMessage(SseMessageDto sseMessageDto) { |
| | | if (SSE_ENABLE) { |
| | | if (!isEnable()) { |
| | | return; |
| | | } |
| | | MANAGER.publishMessage(sseMessageDto); |
| | |
| | | * @param message 要发布的消息内容 |
| | | */ |
| | | public static void publishAll(String message) { |
| | | if (SSE_ENABLE) { |
| | | if (!isEnable()) { |
| | | return; |
| | | } |
| | | MANAGER.publishAll(message); |
| | | } |
| | | |
| | | /** |
| | | * 是否开启 |
| | | */ |
| | | public static Boolean isEnable() { |
| | | return SSE_ENABLE; |
| | | } |
| | | |
| | | } |