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();
|
}
|
}
|
