新增:rpc 构建方法 render 相关方法;

过时:rpc build 系列方法标注;
This commit is contained in:
梁显优 2023-04-15 01:02:58 +08:00
parent a8788b419d
commit 558c29912d
2 changed files with 46 additions and 1 deletions

View File

@ -2,6 +2,7 @@ package com.zdemo.zhub;
import org.redkale.convert.ConvertColumn;
import org.redkale.convert.json.JsonConvert;
import org.redkale.service.RetResult;
public class Rpc<T> {
private String ruk; // request unique key:
@ -13,7 +14,7 @@ public class Rpc<T> {
public Rpc() {
}
public Rpc(String appname, String ruk, String topic, Object value) {
protected Rpc(String appname, String ruk, String topic, Object value) {
this.ruk = appname + "::" + ruk;
this.topic = topic;
this.value = (T) JsonConvert.root().convertTo(value);
@ -57,12 +58,14 @@ public class Rpc<T> {
return ruk.split("::")[0];
}
@Deprecated(since = "2023.04.15")
public <R> RpcResult<R> buildResp() {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
return response;
}
@Deprecated(since = "2023.04.15")
public <R> RpcResult<R> buildResp(int retcode, String retinfo) {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
@ -71,6 +74,7 @@ public class Rpc<T> {
return response;
}
@Deprecated(since = "2023.04.15")
public <R> RpcResult<R> buildError(String retinfo) {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
@ -79,10 +83,50 @@ public class Rpc<T> {
return response;
}
@Deprecated(since = "2023.04.15")
public <R> RpcResult<R> buildResp(R result) {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
response.setResult(result);
return response;
}
public <R> RpcResult<R> render() {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
return response;
}
public RpcResult render(RetResult result) {
RpcResult resp = new RpcResult<>();
resp.setRuk(ruk);
resp.setRetcode(result.getRetcode());
resp.setRetinfo(result.getRetinfo());
resp.setResult(result.getResult());
return resp;
}
public <R> RpcResult<R> render(R result) {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
response.setResult(result);
return response;
}
public <R> RpcResult<R> retError(String retinfo) {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
response.setRetcode(100);
response.setRetinfo(retinfo);
return response;
}
public <R> RpcResult<R> retError(int retcode, String retinfo) {
RpcResult<R> response = new RpcResult<>();
response.setRuk(ruk);
response.setRetcode(retcode);
response.setRetinfo(retinfo);
return response;
}
}

View File

@ -504,6 +504,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
send("timer", name);
}
@Deprecated
public void reloadTimer() {
send("cmd", "reload-timer");
}