Changeset 22 for trunk/objectmq/src/omq/common/util/OmqConnectionFactory.java

Timestamp:

05/23/13 21:37:28 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/objectmq/src/omq/common/util/OmqConnectionFactory.java (modified) (2 diffs)

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

@@ -17 +17 @@
 public class OmqConnectionFactory {
         private static Connection connection;
+        private static int connectionTimeout = 2 * 1000;
 
         public static void init(Properties env) throws KeyManagementException, NoSuchAlgorithmException, IOException {
@@ -41 +42 @@
                 factory.setHost(host);
                 factory.setPort(port);
+                factory.setConnectionTimeout(connectionTimeout);
                 if (ssl) {
                         factory.useSslProtocol();