|
@@ -36,7 +36,7 @@ public class SSEService {
|
|
|
|
|
|
SseEmitter sseEmitter = sseMap.get(uid);
|
|
SseEmitter sseEmitter = sseMap.get(uid);
|
|
try {
|
|
try {
|
|
- sseEmitter.send(msg);
|
|
|
|
|
|
+ sseEmitter.send(SseEmitter.event().name("message").data(msg));
|
|
return true;
|
|
return true;
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new BizException("推送消息失败");
|
|
throw new BizException("推送消息失败");
|