89 lines
2.0 KiB
Java
89 lines
2.0 KiB
Java
package com.zdemo.zhub;
|
|
|
|
import org.redkale.convert.ConvertColumn;
|
|
import org.redkale.convert.json.JsonConvert;
|
|
|
|
public class Rpc<T> {
|
|
private String ruk; // request unique key:
|
|
private String topic; // call topic
|
|
private T value; // call paras
|
|
|
|
private RpcResult rpcResult;
|
|
|
|
public Rpc() {
|
|
}
|
|
|
|
public Rpc(String appname, String ruk, String topic, Object value) {
|
|
this.ruk = appname + "::" + ruk;
|
|
this.topic = topic;
|
|
this.value = (T) JsonConvert.root().convertTo(value);
|
|
}
|
|
|
|
public String getRuk() {
|
|
return ruk;
|
|
}
|
|
|
|
public void setRuk(String ruk) {
|
|
this.ruk = ruk;
|
|
}
|
|
|
|
public String getTopic() {
|
|
return topic;
|
|
}
|
|
|
|
public void setTopic(String topic) {
|
|
this.topic = topic;
|
|
}
|
|
|
|
public T getValue() {
|
|
return value;
|
|
}
|
|
|
|
public void setValue(T value) {
|
|
this.value = value;
|
|
}
|
|
|
|
@ConvertColumn(ignore = true)
|
|
public RpcResult getRpcResult() {
|
|
return rpcResult;
|
|
}
|
|
|
|
public void setRpcResult(RpcResult rpcResult) {
|
|
this.rpcResult = rpcResult;
|
|
}
|
|
|
|
@ConvertColumn(ignore = true)
|
|
public String getBackTopic() {
|
|
return ruk.split("::")[0];
|
|
}
|
|
|
|
public <R> RpcResult<R> buildResp() {
|
|
RpcResult<R> response = new RpcResult<>();
|
|
response.setRuk(ruk);
|
|
return response;
|
|
}
|
|
|
|
public <R> RpcResult<R> buildResp(int retcode, String retinfo) {
|
|
RpcResult<R> response = new RpcResult<>();
|
|
response.setRuk(ruk);
|
|
response.setRetcode(retcode);
|
|
response.setRetinfo(retinfo);
|
|
return response;
|
|
}
|
|
|
|
public <R> RpcResult<R> buildError(String retinfo) {
|
|
RpcResult<R> response = new RpcResult<>();
|
|
response.setRuk(ruk);
|
|
response.setRetcode(100);
|
|
response.setRetinfo(retinfo);
|
|
return response;
|
|
}
|
|
|
|
public <R> RpcResult<R> buildResp(R result) {
|
|
RpcResult<R> response = new RpcResult<>();
|
|
response.setRuk(ruk);
|
|
response.setResult(result);
|
|
return response;
|
|
}
|
|
}
|