Changeset 72 for trunk/src/main/java/omq/common/util/Serializer.java

Timestamp:

06/29/13 20:44:27 (11 years ago)

Author:

stoda

Message:

Events deleted instead of them there's a new example of how to use the observer pattern

File:

• trunk/src/main/java/omq/common/util/Serializer.java (modified) (5 diffs)

trunk/src/main/java/omq/common/util/Serializer.java

@@ -4 +4 @@
 import java.util.Properties;
 
-import omq.common.event.Event;
 import omq.common.message.Request;
 import omq.common.message.Response;
@@ -48 +47 @@
                         try {
                                 String className = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
-                                
+
                                 if (className == null || className.isEmpty()) {
                                         throw new ClassNotFoundException("Class name is null or empty.");
                                 }
-                                
+
                                 serializer = getInstance(className);
                         } catch (Exception ex) {
@@ -62 +61 @@
         }
 
-        public ISerializer getInstance(String type) throws SerializerException {                                
+        public ISerializer getInstance(String type) throws SerializerException {
                 if (KRYO.equals(type)) {
                         if (kryoSerializer == null) {
@@ -79 +78 @@
                         return javaSerializer;
                 }
-                
+
                 throw new SerializerException("Serializer not found.");
         }
@@ -148 +147 @@
         }
 
-        public Event deserializeEvent(byte[] bytes) throws SerializerException {
-                ISerializer instance = getInstance();
-
-                Boolean enableCompression = getEnableCompression();
-                if (enableCompression) {
-                        try {
-                                byte[] unZippedBytes = Zipper.unzip(bytes);
-                                return instance.deserializeEvent(unZippedBytes);
-                        } catch (IOException e) {
-                                throw new SerializerException(e.getMessage(), e);
-                        }
-                } else {
-                        return instance.deserializeEvent(bytes);
-                }
-        }
-
-        // public static void removeSerializers() {
-        // logger.warn("Removing serializers");
-        // serializer = null;
-        // kryoSerializer = null;
-        // javaSerializer = null;
-        // gsonSerializer = null;
-        // }
 }