diff --git a/src/org/redkale/net/sncp/SncpClient.java b/src/org/redkale/net/sncp/SncpClient.java index 05db0006c..5681b0ff7 100644 --- a/src/org/redkale/net/sncp/SncpClient.java +++ b/src/org/redkale/net/sncp/SncpClient.java @@ -307,7 +307,7 @@ public final class SncpClient { byte i; while ((i = reader.readByte()) != 0) { final Attribute attr = action.paramAttrs[i]; - attr.set(params[i - 1], bsonConvert.convertFrom(attr.type(), reader)); + attr.set(params[i - 1], bsonConvert.convertFrom(attr.genericType(), reader)); } Object rs = bsonConvert.convertFrom(Object.class, reader); @@ -327,7 +327,7 @@ public final class SncpClient { byte i; while ((i = reader.readByte()) != 0) { final Attribute attr = action.paramAttrs[i]; - attr.set(params[i - 1], bsonConvert.convertFrom(attr.type(), reader)); + attr.set(params[i - 1], bsonConvert.convertFrom(attr.genericType(), reader)); } return bsonConvert.convertFrom(action.handlerFuncParamIndex >= 0 ? Object.class : action.resultTypes, reader); } catch (RpcRemoteException re) { @@ -471,7 +471,7 @@ public final class SncpClient { int i; while ((i = (reader.readByte() & 0xff)) != 0) { final Attribute attr = action.paramAttrs[i]; - attr.set(params[i - 1], bsonConvert.convertFrom(attr.type(), reader)); + attr.set(params[i - 1], bsonConvert.convertFrom(attr.genericType(), reader)); } Object rs = bsonConvert.convertFrom(action.handlerFuncParamIndex >= 0 ? Object.class : action.resultTypes, reader); handler.completed(rs, handlerAttach); diff --git a/src/org/redkale/net/sncp/SncpDynServlet.java b/src/org/redkale/net/sncp/SncpDynServlet.java index a3a8352a5..aded1a62b 100644 --- a/src/org/redkale/net/sncp/SncpDynServlet.java +++ b/src/org/redkale/net/sncp/SncpDynServlet.java @@ -196,7 +196,7 @@ public final class SncpDynServlet extends SncpServlet { org.redkale.util.Attribute attr = paramAttrs[i]; if (attr == null) continue; out.writeByte((byte) i); - convert.convertTo(out, attr.type(), attr.get(params[i - 1])); + convert.convertTo(out, attr.genericType(), attr.get(params[i - 1])); } } out.writeByte((byte) 0);