ry-saas/hx-socket/src/main/java/com/fjhx/socket/event/WebSocketSendFailEvent.java

package com.fjhx.socket.event;


import com.fjhx.socket.entity.MessageEntity;
import com.fjhx.socket.service.WebSocketServer;
import lombok.Getter;
import org.springframework.context.ApplicationEvent;

/**
 * webStock推送消息失败事件
 */
@Getter
public class WebSocketSendFailEvent extends ApplicationEvent {

    private final MessageEntity messageEntity;

    public WebSocketSendFailEvent(WebSocketServer source, MessageEntity messageEntity) {
        super(source);
        this.messageEntity = messageEntity;
    }

    @Override
    public WebSocketServer getSource() {
        return (WebSocketServer) super.getSource();
    }

}