package com.xiaopeng.api.factory.pushMessage;
|
|
import com.xiaopeng.api.dto.pushMessage.AliPushMessageDTO;
|
import com.xiaopeng.api.feignClient.pushMessage.WebSocketMessageClient;
|
import com.xiaopeng.api.vo.TaskVO;
|
import com.xiaopeng.common.core.domain.R;
|
import org.springframework.cloud.openfeign.FallbackFactory;
|
|
public class WebSocketMessageFallbackFactory implements FallbackFactory<WebSocketMessageClient> {
|
@Override
|
public WebSocketMessageClient create(Throwable cause) {
|
return new WebSocketMessageClient() {
|
@Override
|
public R<String> pushTask(TaskVO dto) {
|
return R.fail("发送失败");
|
}
|
|
};
|
}
|
}
|
