package cn.iocoder.yudao.module.infra.api.websocket;
|
|
import cn.iocoder.yudao.framework.websocket.core.sender.WebSocketMessageSender;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* WebSocket 发送器的 API 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Component
|
public class WebSocketSenderApiImpl implements WebSocketSenderApi {
|
|
@SuppressWarnings("SpringJavaAutowiredFieldsWarningInspection")
|
@Autowired(required = false) // 由于 yudao.websocket.enable 配置项，可以关闭 WebSocket 的功能，所以这里只能不强制注入
|
private WebSocketMessageSender webSocketMessageSender;
|
|
@Override
|
public void send(Integer userType, Long userId, String messageType, String messageContent) {
|
webSocketMessageSender.send(userType, userId, messageType, messageContent);
|
}
|
|
@Override
|
public void send(Integer userType, String messageType, String messageContent) {
|
webSocketMessageSender.send(userType, messageType, messageContent);
|
}
|
|
@Override
|
public void send(String sessionId, String messageType, String messageContent) {
|
webSocketMessageSender.send(sessionId, messageType, messageContent);
|
}
|
|
}
|
