Index: trunk/src/main/java/omq/common/util/OmqConnectionFactory.java
===================================================================
--- trunk/src/main/java/omq/common/util/OmqConnectionFactory.java	(revision 50)
+++ trunk/src/main/java/omq/common/util/OmqConnectionFactory.java	(revision 51)
@@ -39,5 +39,8 @@
 			} 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);
 			}