From d49c11fbec2a17c39687f05d1c6faeb3983539be Mon Sep 17 00:00:00 2001 From: YunaiV Date: Sat, 28 Dec 2024 19:17:55 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E6=8B=BC=E5=86=99=E4=BF=AE=E6=AD=A3?= =?UTF-8?q?=E3=80=91KafkaWebSocketMessageConsumer=20=E7=9A=84=20kafkaWebSo?= =?UTF-8?q?cketMessageSender=20=E6=8B=BC=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/sender/kafka/KafkaWebSocketMessageConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/sender/kafka/KafkaWebSocketMessageConsumer.java b/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/sender/kafka/KafkaWebSocketMessageConsumer.java index 201e65d81f..4b255b9326 100644 --- a/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/sender/kafka/KafkaWebSocketMessageConsumer.java +++ b/yudao-framework/yudao-spring-boot-starter-websocket/src/main/java/cn/iocoder/yudao/framework/websocket/core/sender/kafka/KafkaWebSocketMessageConsumer.java @@ -12,7 +12,7 @@ @RequiredArgsConstructor public class KafkaWebSocketMessageConsumer { - private final KafkaWebSocketMessageSender rabbitMQWebSocketMessageSender; + private final KafkaWebSocketMessageSender kafkaWebSocketMessageSender; @RabbitHandler @KafkaListener( @@ -20,7 +20,7 @@ public class KafkaWebSocketMessageConsumer { // 在 Group 上，使用 UUID 生成其后缀。这样，启动的 Consumer 的 Group 不同，以达到广播消费的目的 groupId = "${yudao.websocket.sender-kafka.consumer-group}" + "-" + "#{T(java.util.UUID).randomUUID()}") public void onMessage(KafkaWebSocketMessage message) { - rabbitMQWebSocketMessageSender.send(message.getSessionId(), + kafkaWebSocketMessageSender.send(message.getSessionId(), message.getUserType(), message.getUserId(), message.getMessageType(), message.getMessageContent()); }