Changeset 62 for trunk/src/main/java/omq/common

Timestamp:

06/26/13 11:20:06 (11 years ago)

Author:

gguerrero

Message:

 

Location:

trunk

Files:

• . (modified) (1 prop)
• src/main/java/omq/common/util/Serializer.java (modified) (4 diffs)

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

@@ -22 +22 @@
         // private static final Logger logger =
         // Logger.getLogger(Serializer.class.getName());
-        public static final String kryo = "kryo";
-        public static final String java = "java";
-        public static final String gson = "gson";
+        public static final String KRYO = "kryo";
+        public static final String JAVA = "java";
+        public static final String GSON = "gson";
 
         // Client serializer
@@ -47 +47 @@
                 if (serializer == null) {
                         try {
-                                String className = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
-
+                                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 +62 @@
         }
 
-        public ISerializer getInstance(String type) throws SerializerException {
-                if (kryo.equals(type)) {
+        public ISerializer getInstance(String type) throws SerializerException {                                
+                if (KRYO.equals(type)) {
                         if (kryoSerializer == null) {
                                 kryoSerializer = new KryoImp();
                         }
                         return kryoSerializer;
-                } else if (gson.endsWith(type)) {
+                } else if (GSON.equals(type)) {
                         if (gsonSerializer == null) {
                                 gsonSerializer = new GsonImp();
                         }
                         return gsonSerializer;
-                } else {
+                } else if (JAVA.equals(type)) {
                         if (javaSerializer == null) {
                                 javaSerializer = new JavaImp();
@@ -79 +79 @@
                         return javaSerializer;
                 }
+                
+                throw new SerializerException("Serializer not found.");
         }