|
@@ -22,7 +22,6 @@ public class MsgConsumer {
|
|
|
public void processTopicMsg(Message message) {
|
|
|
String sid = message.getMessageProperties().getReceivedRoutingKey().split("\\.")[1];
|
|
|
String msg = new String(message.getBody(), StandardCharsets.UTF_8);
|
|
|
- log.info("[rabbit] sid: {}, msg: {}", sid, msg);
|
|
|
WebSocketServer.sendMessage(sid, msg);
|
|
|
}
|
|
|
}
|