Changeset 62 for trunk/src/main


Ignore:
Timestamp:
06/26/13 11:20:06 (11 years ago)
Author:
gguerrero
Message:
 
Location:
trunk
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • trunk

    • Property svn:ignore set to
      target
  • trunk/src/main/java/omq/client/proxy/Proxymq.java

    r59 r62  
    9898
    9999                // set the serializer type
    100                 serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
     100                serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
    101101
    102102                listeners = new HashMap<String, EventListener<?>>();
  • trunk/src/main/java/omq/common/util/Serializer.java

    r53 r62  
    2222        // private static final Logger logger =
    2323        // Logger.getLogger(Serializer.class.getName());
    24         public static final String kryo = "kryo";
    25         public static final String java = "java";
    26         public static final String gson = "gson";
     24        public static final String KRYO = "kryo";
     25        public static final String JAVA = "java";
     26        public static final String GSON = "gson";
    2727
    2828        // Client serializer
     
    4747                if (serializer == null) {
    4848                        try {
    49                                 String className = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
    50 
     49                                String className = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
     50                               
    5151                                if (className == null || className.isEmpty()) {
    5252                                        throw new ClassNotFoundException("Class name is null or empty.");
    5353                                }
    54 
     54                               
    5555                                serializer = getInstance(className);
    5656                        } catch (Exception ex) {
     
    6262        }
    6363
    64         public ISerializer getInstance(String type) throws SerializerException {
    65                 if (kryo.equals(type)) {
     64        public ISerializer getInstance(String type) throws SerializerException {                               
     65                if (KRYO.equals(type)) {
    6666                        if (kryoSerializer == null) {
    6767                                kryoSerializer = new KryoImp();
    6868                        }
    6969                        return kryoSerializer;
    70                 } else if (gson.endsWith(type)) {
     70                } else if (GSON.equals(type)) {
    7171                        if (gsonSerializer == null) {
    7272                                gsonSerializer = new GsonImp();
    7373                        }
    7474                        return gsonSerializer;
    75                 } else {
     75                } else if (JAVA.equals(type)) {
    7676                        if (javaSerializer == null) {
    7777                                javaSerializer = new JavaImp();
     
    7979                        return javaSerializer;
    8080                }
     81               
     82                throw new SerializerException("Serializer not found.");
    8183        }
    8284
  • trunk/src/main/java/omq/exception/SerializerException.java

    r44 r62  
    88        private static final long serialVersionUID = 1L;
    99
     10        public SerializerException(String message) {
     11                super(message);
     12        }       
     13       
    1014        public SerializerException(String message, Throwable cause) {
    1115                super(message, cause);
Note: See TracChangeset for help on using the changeset viewer.