From 4a7db13ce3f75bc0dc906b1c9ae994fb6577cbea Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A2=81=E6=98=BE=E4=BC=98?= <237809796@qq.com>
Date: Wed, 5 Apr 2023 15:53:00 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=EF=BC=9A1=E3=80=81rpcSubscri?=
 =?UTF-8?q?be=20=E9=87=8D=E8=BD=BD=E6=96=B9=E6=B3=95=EF=BC=9B2=E3=80=81ITy?=
 =?UTF-8?q?pe=20=E7=9A=84=E7=B1=BB=E5=9E=8B=E5=80=BC=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/zdemo/IType.java           | 12 ++++++++++++
 src/com/zdemo/zhub/ZHubClient.java | 10 ++++++----
 2 files changed, 18 insertions(+), 4 deletions(-)

diff --git a/src/com/zdemo/IType.java b/src/com/zdemo/IType.java
index a8526f7..2e89fbd 100644
--- a/src/com/zdemo/IType.java
+++ b/src/com/zdemo/IType.java
@@ -13,9 +13,21 @@ public interface IType {
     TypeToken<Integer> INT = new TypeToken<Integer>() {
     };
 
+    TypeToken<Short> SHORT = new TypeToken<Short>() {
+    };
+
+    TypeToken<Long> LONG = new TypeToken<Long>() {
+    };
+
     TypeToken<Map<String, String>> MAP = new TypeToken<Map<String, String>>() {
     };
 
     TypeToken<List<Map<String, String>>> LMAP = new TypeToken<List<Map<String, String>>>() {
     };
+
+    TypeToken<List<String>> LSTRING = new TypeToken<List<String>>() {
+    };
+
+    TypeToken<List<Integer>> LINT = new TypeToken<List<Integer>>() {
+    };
 }
diff --git a/src/com/zdemo/zhub/ZHubClient.java b/src/com/zdemo/zhub/ZHubClient.java
index 182af29..665729b 100644
--- a/src/com/zdemo/zhub/ZHubClient.java
+++ b/src/com/zdemo/zhub/ZHubClient.java
@@ -1,9 +1,6 @@
 package com.zdemo.zhub;
 
-import com.zdemo.AbstractConsumer;
-import com.zdemo.Event;
-import com.zdemo.IConsumer;
-import com.zdemo.IProducer;
+import com.zdemo.*;
 import net.tccn.timer.Timers;
 import org.redkale.service.Service;
 import org.redkale.util.*;
@@ -610,6 +607,11 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
     // -- 订阅端 --
     private Set<String> rpcTopics = new HashSet();
 
+    @Comment("rpc call consumer")
+    public <R> void rpcSubscribe(String topic, Function<Rpc<String>, RpcResult<R>> fun) {
+        rpcSubscribe(topic, IType.STRING, fun);
+    }
+
     @Comment("rpc call consumer")
     public <T, R> void rpcSubscribe(String topic, TypeToken<T> typeToken, Function<Rpc<T>, RpcResult<R>> fun) {
         Consumer<String> consumer = v -> {