package com.walker.push.rocketmq.tcp;

import com.walker.queue.MqBaseMessage;
import com.walker.tcp.Request;

/**
 * 平台消息队列中，针对长连接定义的消息。
 * @author 时克英
 * @date 2023-09-19
 */
public class MqRequest extends MqBaseMessage {

    public Request<?> getRequest() {
        return request;
    }

    public void setRequest(Request<?> request) {
        this.request = request;
    }

    private Request<?> request;

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