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 -> {