diff --git a/pom.xml b/pom.xml index bf36328..df9e7fd 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ net.tccn zhub-client-redkale - 0.1.1-dev + 0.1.3.dev 17 diff --git a/src/main/java/net/tccn/zhub/RpcResult.java b/src/main/java/net/tccn/zhub/RpcResult.java index 5802515..6f5bf87 100644 --- a/src/main/java/net/tccn/zhub/RpcResult.java +++ b/src/main/java/net/tccn/zhub/RpcResult.java @@ -34,7 +34,7 @@ public class RpcResult { return result; } - public void setResult(Object result) { - this.result = (R) result; + public void setResult(R result) { + this.result = result; } } diff --git a/src/main/java/net/tccn/zhub/ZHubClient.java b/src/main/java/net/tccn/zhub/ZHubClient.java index 65aeffe..5e6412c 100644 --- a/src/main/java/net/tccn/zhub/ZHubClient.java +++ b/src/main/java/net/tccn/zhub/ZHubClient.java @@ -679,7 +679,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer TypeToken typeToken = rpc.getTypeToken(); if (typeToken.getType() != ((RpcResult) value).getResult().getClass()) { Object result = convert.convertFrom(typeToken.getType(), toStr(((RpcResult) value).getResult())); - ((RpcResult) value).setResult(result); + ((RpcResult) value).setResult(result); } rpc.setRpcResult((RpcResult) value); @@ -725,7 +725,8 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer Rpc rpc = null; try { if (v instanceof String) { - rpc = convert.convertFrom(IType.STRING.getType(), (String) v); + rpc = convert.convertFrom(new TypeToken>() { + }.getType(), (String) v); } else { rpc = (Rpc) v; }