Changeset 6 for objectmq/src/omq/common/util/Serializers/JsonImp.java

Timestamp:

05/09/13 17:34:07 (12 years ago)

Author:

stoda

Message:

Objectmq working (there are no remote Exceptions, and you cannot send remoteObjects through the web, but you can make proxies)

File:

• objectmq/src/omq/common/util/Serializers/JsonImp.java (modified) (3 diffs)

objectmq/src/omq/common/util/Serializers/JsonImp.java

@@ -1 +1 @@
 package omq.common.util.Serializers;
 
-import omq.common.message.request.AsyncRequest;
-import omq.common.message.request.SyncRequest;
-import omq.common.message.response.CollectionResponse;
-import omq.common.message.response.DefaultResponse;
-import omq.common.message.response.ExceptionResponse;
-import omq.common.message.response.ProxyResponse;
-import omq.common.message.response.Response;
 import omq.exception.SerializerException;
 
@@ -20 +13 @@
 public class JsonImp implements ISerializer {
         private final ObjectMapper mapper = new ObjectMapper();
-        
+
         @Override
         public byte[] serialize(Object obj) throws SerializerException {
@@ -30 +23 @@
                 }
         }
-        
+
         @Override
         public byte[] serialize(Object obj, Class<?> clazz) throws SerializerException {
                 return serialize(obj);
-        }       
-        
-        
-        private Object tryDeserialize(byte[] bytes, Class<?> clazz) throws Exception{
+        }
+
+        private Object tryDeserialize(byte[] bytes, Class<?> clazz) throws Exception {
                 Object object = mapper.readValue(bytes, clazz);
                 return object;
         }
-        
 
         @Override
         public Object deserialize(byte[] bytes) throws SerializerException {
-                try {
-                        return tryDeserialize(bytes, SyncRequest.class);
-                } catch (Exception e) {
-                        try {
-                                return tryDeserialize(bytes, AsyncRequest.class);
-                        } catch (Exception e1) {                                
-                                try {
-                                        return tryDeserialize(bytes, CollectionResponse.class);                                 
-                                } catch (Exception e2) {
-                                        try {
-                                                return tryDeserialize(bytes, DefaultResponse.class);                                    
-                                        } catch (Exception e3) {                                                
-                                                try {
-                                                        return tryDeserialize(bytes, ExceptionResponse.class);                                  
-                                                } catch (Exception e4) {                                                        
-                                                        try {
-                                                                return tryDeserialize(bytes, ProxyResponse.class);                                      
-                                                        } catch (Exception e5) {                                                                
-                                                                try {
-                                                                        return tryDeserialize(bytes, Response.class);                                   
-                                                                } catch (Exception e6) {
-                                                                        throw new SerializerException("Deserialize -> " + e6.getMessage(), e6);
-                                                                }                                                               
-                                                        }                                                       
-                                                }                                               
-                                        }
-                                }                               
-                        } 
-                }
+                // try {
+                // return tryDeserialize(bytes, SyncRequest.class);
+                // } catch (Exception e) {
+                // try {
+                // return tryDeserialize(bytes, AsyncRequest.class);
+                // } catch (Exception e1) {
+                // try {
+                // return tryDeserialize(bytes, CollectionResponse.class);
+                // } catch (Exception e2) {
+                // try {
+                // return tryDeserialize(bytes, DefaultResponse.class);
+                // } catch (Exception e3) {
+                // try {
+                // return tryDeserialize(bytes, ExceptionResponse.class);
+                // } catch (Exception e4) {
+                // try {
+                // return tryDeserialize(bytes, ProxyResponse.class);
+                // } catch (Exception e5) {
+                // try {
+                // return tryDeserialize(bytes, Response.class);
+                // } catch (Exception e6) {
+                // throw new SerializerException("Deserialize -> " + e6.getMessage(),
+                // e6);
+                // }
+                // }
+                // }
+                // }
+                // }
+                // }
+                // }
+                return null;
         }