package com.tianbo.messagebus.myinterface;


import com.tianbo.messagebus.controller.response.ResultJson;
import com.tianbo.messagebus.model.MSGS;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;


@Slf4j
@Service("myKafkaSend")
public class KafkaSendFallback implements KafkaSendApi {

    @Override
    public ResultJson send(MSGS msgs) {
        return new ResultJson<>("10400","发送消息失败");
    }
}