diff src/main/java/christie/daemon/IncomingTcpConnection.java @ 13:bcd4f2c19185

don't work MessagePack unconvert for remote put
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Wed, 10 Jan 2018 20:37:47 +0900
parents b49a926cbdd9
children f2b30b47ef67
line wrap: on
line diff
--- a/src/main/java/christie/daemon/IncomingTcpConnection.java	Tue Jan 09 17:37:43 2018 +0900
+++ b/src/main/java/christie/daemon/IncomingTcpConnection.java	Wed Jan 10 20:37:47 2018 +0900
@@ -46,8 +46,11 @@
                 switch (type) {
                     case PUT:
                         connection.socket.getInputStream().read(data);
-
-                        cgms.get(msg.cgmName).getDGM().put(msg.key, data);
+                        try {
+                            cgms.get(msg.cgmName).getDGM().put(msg.key, new DataGear(data, Class.forName(msg.clazz)));
+                        } catch (ClassNotFoundException e) {
+                            e.printStackTrace();
+                        }
 
                         break;
                         /*