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

Timestamp:

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

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/common/util/OmqConnectionFactory.java (modified) (4 diffs)

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;
         }
 }