package com.walker.push.rocketmq.tcp;

import com.walker.queue.MqBaseMessage;

/**
 * 平台消息队列中，针对长连接定义的消息响应对象。
 * @author 时克英
 * @date 2023-09-19
 * @date 2023-09-28 由于序列化问题，修改<code>response</code>对象为Json字符串，在MQ消息接收时，按照协议具体实现。
 */
public class MqResponse extends MqBaseMessage {

    public MqResponse(){}

//    public Response<?> getResponse() {
//        return response;
//    }
//
//    public void setResponse(Response<?> response) {
//        this.response = response;
//    }
//
//    private Response<?> response;

    public String getResponse() {
        return response;
    }

    public void setResponse(String response) {
        this.response = response;
    }

    private String response;

    @Override
    public String toString() {
        return new StringBuilder("MqRequest{").append("request=").append(this.response)
                .append(", ").append(super.toString()).append("}").toString();
    }
}