|
@@ -39,10 +39,13 @@ public class SseController {
|
|
|
logger.debug("msg", "3");
|
|
|
sseService.monitor(token, sseEmitter);
|
|
|
logger.debug("msg", "4");
|
|
|
+ sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
|
|
|
poolExecutor.execute(() -> {
|
|
|
try {
|
|
|
Thread.sleep(1000);
|
|
|
sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
|
|
|
+ Thread.sleep(1000);
|
|
|
+ sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
|
|
|
} catch (Exception e) {
|
|
|
logger.error("error", e);
|
|
|
}
|