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 +
|
// '}';
|
}
|
}
|
