Changeset 50 for trunk

Timestamp:

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

Author:

stoda

Message:

 

Location:

trunk

Files:

• logs (added)
• src/main/java/omq/client/listener/ResponseListener.java (modified) (1 diff)
• src/main/java/omq/common/broker/Broker.java (modified) (1 diff)
• src/main/java/omq/common/util/Serializers/GsonImp.java (modified) (1 diff)

trunk/src/main/java/omq/client/listener/ResponseListener.java

@@ -67 +67 @@
                                 // Get the response with its uid
                                 uid_request = delivery.getProperties().getCorrelationId();
-                                System.out.println("Response received -> " + uid_request);
+                                logger.debug("Response received -> proxy reference: " + props.getAppId() + ", corrId: " + uid_request);
 
                                 // Stores the new response

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

@@ -202 +202 @@
                 String UID = event.getTopic();
                 EventWrapper wrapper = new EventWrapper(event);
-                System.out.println("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
+                logger.debug("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
                 channel.exchangeDeclare(UID, "fanout");
 

trunk/src/main/java/omq/common/util/Serializers/GsonImp.java

@@ -79 +79 @@
                 try {
                         String json = new String(bytes);
-                        System.out.println(json);
 
                         JsonParser parser = new JsonParser();