From 4d125f8e46f728735d764624cb5a9b929c87b829 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=9D=E5=B0=98?= <237809796@qq.com>
Date: Mon, 22 Apr 2024 00:13:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=EF=BC=9Arpc=20=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E8=A7=A3=E6=9E=90=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                     | 2 +-
 src/main/java/net/tccn/zhub/RpcResult.java  | 4 ++--
 src/main/java/net/tccn/zhub/ZHubClient.java | 5 +++--
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index bf36328..df9e7fd 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>net.tccn</groupId>
     <artifactId>zhub-client-redkale</artifactId>
-    <version>0.1.1-dev</version>
+    <version>0.1.3.dev</version>
 
     <properties>
         <maven.compiler.source>17</maven.compiler.source>
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<R> {
         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<Object>) value).setResult(result);
             }
 
             rpc.setRpcResult((RpcResult) value);
@@ -725,7 +725,8 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
             Rpc<T> rpc = null;
             try {
                 if (v instanceof String) {
-                    rpc = convert.convertFrom(IType.STRING.getType(), (String) v);
+                    rpc = convert.convertFrom(new TypeToken<Rpc<String>>() {
+                    }.getType(), (String) v);
                 } else {
                     rpc = (Rpc<T>) v;
                 }