.

src/com/zdemo/AbstractConsumer.java

@@ -61,7 +61,7 @@ public abstract class AbstractConsumer implements IConsumer {
     protected abstract void subscribe(String topic);
 
     public void subscribe(String topic, Consumer<String> consumer) {
-        subscribe(topic, TYPE_TOKEN_STRING, consumer);
+        subscribe(topic, IType.STRING, consumer);
     }
 
     @Override

src/com/zdemo/IConsumer.java

@@ -5,10 +5,6 @@ import org.redkale.util.TypeToken;
 import java.util.function.Consumer;
 
 public interface IConsumer {
-    TypeToken<String> TYPE_TOKEN_STRING = new TypeToken<String>() {
-    };
-    TypeToken<Integer> TYPE_TOKEN_INT = new TypeToken<Integer>() {
-    };
 
     /**
      * 取消订阅

src/com/zdemo/IType.java

@@ -0,0 +1,21 @@
+package com.zdemo;
+
+import org.redkale.util.TypeToken;
+
+import java.util.List;
+import java.util.Map;
+
+public interface IType {
+
+    TypeToken<String> STRING = new TypeToken<String>() {
+    };
+
+    TypeToken<Integer> INT = new TypeToken<Integer>() {
+    };
+
+    TypeToken<Map<String, String>> MAP = new TypeToken<Map<String, String>>() {
+    };
+
+    TypeToken<List<Map<String, String>>> LMAP = new TypeToken<List<Map<String, String>>>() {
+    };
+}

test/com/zdemo/test/HelloService.java

@@ -1,6 +1,6 @@
 package com.zdemo.test;
 
-import com.zdemo.IConsumer;
+import com.zdemo.IType;
 import com.zdemo.zhub.RpcResult;
 import com.zdemo.zhub.ZHubClient;
 import org.redkale.net.http.RestMapping;
@@ -91,12 +91,12 @@ public class HelloService implements Service {
             //System.out.println(x.getResult().get("v"));
         }
 
-        return zhub.rpc("x", v, IConsumer.TYPE_TOKEN_STRING);
+        return zhub.rpc("x", v, IType.STRING);
     }
 
     @RestMapping
     public RpcResult<String> d(String v) {
-        RpcResult<String> rpc = zhub.rpc("x", v, IConsumer.TYPE_TOKEN_STRING);
+        RpcResult<String> rpc = zhub.rpc("x", v, IType.STRING);
         return rpc;
     }