package com.ruoyi.other.api.factory; import com.ruoyi.common.core.domain.R; import com.ruoyi.other.api.domain.TVip; import com.ruoyi.other.api.dto.WebSocketMsg; import com.ruoyi.other.api.feignClient.VipClient; import com.ruoyi.other.api.feignClient.WebSocketClient; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.cloud.openfeign.FallbackFactory; import org.springframework.stereotype.Component; /** * 会员服务降级处理 * * @author ruoyi */ @Component public class WebSocketFallbackFactory implements FallbackFactory { private static final Logger log = LoggerFactory.getLogger(WebSocketFallbackFactory.class); @Override public WebSocketClient create(Throwable throwable) { log.error("WebSocket调用失败:{}", throwable.getMessage()); return new WebSocketClient() { @Override public R send(WebSocketMsg webSocketMsg) { return R.fail("发送WebSocket消息失败:" + throwable.getMessage()); } }; } }