Changeset 36 for trunk/objectmq/src/omq/common/broker/Broker.java

Timestamp:

06/11/13 18:25:36 (11 years ago)

Author:

stoda

Message:

Fault tolerance in the client side added.
Some refactoring in proxymq, broker, environment and the client listeners

File:

• trunk/objectmq/src/omq/common/broker/Broker.java (modified) (3 diffs)

trunk/objectmq/src/omq/common/broker/Broker.java

@@ -14 +14 @@
 import omq.common.util.ParameterQueue;
 import omq.common.util.Serializer;
-import omq.exception.EnvironmentException;
 import omq.exception.InitBrokerException;
 import omq.exception.RemoteException;
@@ -33 +32 @@
 
         public static void initBroker(Properties env) throws Exception {
-                try {
-                        Environment.getEnvironment();
-                } catch (EnvironmentException ex) { // environment not set.
+                if (Environment.isVoid()) {
                         Environment.setEnvironment(env);
                         connection = OmqConnectionFactory.getNewConnection(env);
@@ -115 +112 @@
                 System.out.println("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
                 channel.exchangeDeclare(UID, "fanout");
-                
+
                 byte[] bytesResponse = Serializer.serialize(wrapper);
                 channel.basicPublish(UID, "", null, bytesResponse);
 
-                //Log.saveLog("Server-Serialize", bytesResponse);                       
+                // Log.saveLog("Server-Serialize", bytesResponse);
         }