diff --git a/src/main/java/com/xydl/cac/controller/TestController.java b/src/main/java/com/xydl/cac/controller/TestController.java index f91465e..fd6a2b7 100644 --- a/src/main/java/com/xydl/cac/controller/TestController.java +++ b/src/main/java/com/xydl/cac/controller/TestController.java @@ -33,7 +33,7 @@ public class TestController extends BasicController { @GetMapping("sendMsg") @ApiOperation("发送消息") - public void sendMsg(String msg) { - webSocketServer.sendMessage(msg , null); + public void sendMsg(String msg, Integer warningId) { + webSocketServer.sendMessage(msg, warningId); } } diff --git a/src/main/java/com/xydl/cac/socket/WebSocketServer.java b/src/main/java/com/xydl/cac/socket/WebSocketServer.java index 1be0d37..ed34aa4 100644 --- a/src/main/java/com/xydl/cac/socket/WebSocketServer.java +++ b/src/main/java/com/xydl/cac/socket/WebSocketServer.java @@ -29,7 +29,7 @@ public class WebSocketServer { log.info("剩余socket连接数" + sessionPools.size()); } - public void sendMessage(String message , Integer warningId) { + public void sendMessage(String message, Integer warningId) { MessageModel msg = new MessageModel(); msg.setType(1); msg.setContent(message);