Changeset 49 for trunk/src/main/java/omq/common/util

Timestamp:

06/19/13 15:59:53 (11 years ago)

Author:

stoda

Message:

log4j added

Location:

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

Files:

• OmqConnectionFactory.java (modified) (4 diffs)
• Serializer.java (modified) (3 diffs)
• Serializers/GsonImp.java (modified) (1 diff)

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

@@ -5 +5 @@
 import java.security.NoSuchAlgorithmException;
 import java.util.Properties;
+
+import org.apache.log4j.Logger;
 
 import com.rabbitmq.client.Channel;
@@ -16 +18 @@
  */
 public class OmqConnectionFactory {
+        private static final Logger logger = Logger.getLogger(OmqConnectionFactory.class.getName());
+
         private static Connection connection;
         private static int connectionTimeout = 2 * 1000;
@@ -34 +38 @@
                                 working = true;
                         } catch (Exception e) {
-                                e.printStackTrace();
+                                logger.error(e);
                                 long milis = Long.parseLong(env.getProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000"));
                                 Thread.sleep(milis);
@@ -64 +68 @@
                         factory.useSslProtocol();
                 }
-                return factory.newConnection();
+
+                Connection connection = factory.newConnection();
+                logger.info("New connection created using: username: " + username + ", host: " + host + ", port: " + port + ", connection timeout: "
+                                + connectionTimeout + " SSL enabled: " + ssl);
+                return connection;
         }
 
         public static Channel getNewChannel() throws IOException {
-                return connection.createChannel();
+                Channel channel = connection.createChannel();
+                logger.info("New channel created using the default connection");
+                return channel;
         }
 }

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

@@ -3 +3 @@
 import java.io.IOException;
 import java.util.Properties;
+
+import org.apache.log4j.Logger;
 
 import omq.common.broker.Broker;
@@ -21 +23 @@
  */
 public class Serializer {
+        private static final Logger logger = Logger.getLogger(Serializer.class.getName());
         public static String kryo = "kryo";
         public static String java = "java";
@@ -158 +161 @@
 
         public static void removeSerializers() {
+                logger.warn("Removing serializers");
                 serializer = null;
                 kryoSerializer = null;

trunk/src/main/java/omq/common/util/Serializers/GsonImp.java

@@ -22 +22 @@
         public byte[] serialize(Object obj) throws SerializerException {
                 String json = gson.toJson(obj);
-                System.out.println(json);
                 return json.getBytes();
         }