package com.highdatas.mdm.util.pool;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.highdatas.mdm.pojo.CodeMsg;
|
import com.highdatas.mdm.pojo.Result;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.http.MediaType;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.io.PrintWriter;
|
|
/**
|
* @author kimi
|
* @description
|
* @date 2020-04-14 12:49
|
*/
|
|
@Slf4j
|
public class MqMessage extends PriorityTask{
|
public MqMessage(String code, HttpServletResponse response) {
|
super(code,response);
|
}
|
|
@Override
|
public void run() {
|
try {
|
log.info("code {} ---------- run", code);
|
Thread.sleep(1000 * 30 * 1);
|
response.setCharacterEncoding("UTF-8");
|
response.setContentType(MediaType.APPLICATION_JSON_VALUE);
|
PrintWriter writer = response.getWriter();
|
writer.write(JSONObject.toJSONString(Result.success(CodeMsg.SUCCESS)));
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
