Changeset 51 for trunk/src/main/java/omq

Timestamp:

06/19/13 16:30:19 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/src/main/java/omq/common/util/OmqConnectionFactory.java (modified) (1 diff)

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

@@ -39 +39 @@
                         } catch (Exception e) {
                                 logger.error(e);
-                                long milis = Long.parseLong(env.getProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000"));
+                                long milis = 2000;
+                                if (env != null) {
+                                        milis = Long.parseLong(env.getProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000"));
+                                }
                                 Thread.sleep(milis);
                         }