Changeset 87


Ignore:
Timestamp:
07/29/13 15:53:58 (11 years ago)
Author:
stoda
Message:
 
Location:
branches/objectmqListeners
Files:
1 deleted
2 edited

Legend:

Unmodified
Added
Removed
  • branches/objectmqListeners/src/main/java/omq/common/broker/Broker.java

    r66 r87  
    22
    33import java.io.IOException;
    4 import java.net.URL;
    54import java.util.HashMap;
    65import java.util.Hashtable;
     
    2322
    2423import org.apache.log4j.Logger;
    25 import org.apache.log4j.xml.DOMConfigurator;
    2624
    2725import com.rabbitmq.client.Channel;
     
    4947        public Broker(Properties env) throws Exception {
    5048                // Load log4j configuration
    51                 URL log4jResource = Broker.class.getResource("/log4j.xml");
    52                 DOMConfigurator.configure(log4jResource);
     49                // URL log4jResource = Broker.class.getResource("/log4j.xml");
     50                // DOMConfigurator.configure(log4jResource);
    5351
    5452                remoteObjs = new HashMap<String, RemoteObject>();
  • branches/objectmqListeners/src/main/java/omq/common/util/Serializer.java

    r62 r87  
    4848                        try {
    4949                                String className = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
    50                                
     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 {                               
     64        public ISerializer getInstance(String type) throws SerializerException {
    6565                if (KRYO.equals(type)) {
    6666                        if (kryoSerializer == null) {
     
    7979                        return javaSerializer;
    8080                }
    81                
    82                 throw new SerializerException("Serializer not found.");
     81
     82                throw new SerializerException("Serializer '" + type + "' not found");
    8383        }
    8484
Note: See TracChangeset for help on using the changeset viewer.