package com.tianbo.messagebus.myinterface;


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

import java.util.ArrayList;
import java.util.List;

@Slf4j
@Service("myKafkaRecive")
public class KafkaReciveFallback implements KafkaReciveApi {

    @Override
    public ResultJson<List<String>> recive(String username) {
        log.info("获取消息失败");
        return new ResultJson<>("400","获取消息失败",new ArrayList<>());
    }
}