Changeset 20

Timestamp:

05/23/13 15:46:29 (11 years ago)

Author:

stoda

Message:

 

Location:

trunk/objectmq/src/omq

Files:

• client/proxy/Proxymq.java (modified) (1 diff)
• client/remote/response/ResponseListener.java (modified) (1 diff)
• common/event/EventDispatcher.java (modified) (1 diff)
• server/remote/request/RemoteObject.java (modified) (3 diffs)

trunk/objectmq/src/omq/client/proxy/Proxymq.java

@@ -121 +121 @@
                 // Publish the request
                 if (request.isAsync()) {
-                        System.out.println("Publish async request ->" + request.getId());
+                        System.out.println("Publish async request -> " + request.getId());
                         publishAsyncRequest(request);
                         return null;
                 } else {
-                        System.out.println("Publish sync request ->" + request.getId());
+                        System.out.println("Publish sync request -> " + request.getId());
                         return publishSyncRequest(request, method.getReturnType());
                 }

trunk/objectmq/src/omq/client/remote/response/ResponseListener.java

@@ -60 +60 @@
                                 // Get the response with its uid
                                 uid_request = delivery.getProperties().getCorrelationId();
-                                System.out.println("Response reveived -> " + uid_request);
+                                System.out.println("Response received -> " + uid_request);
 
                                 // Stores the new response

trunk/objectmq/src/omq/common/event/EventDispatcher.java

@@ -133 +133 @@
                         String queueName = env.getProperty(ParameterQueue.EVENT_REPLY_QUEUE);
                         String reference = e.getTopic();
+
+                        System.out.println("EventDispatcher declaring fanout -> " + reference + " Binding with: " + queueName);
+
                         channel.exchangeDeclare(reference, "fanout");
                         channel.queueBind(queueName, reference, "");

trunk/objectmq/src/omq/server/remote/request/RemoteObject.java

@@ -81 +81 @@
 
                 // Declares and bindings
+                System.out.println("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
                 channel.exchangeDeclare(exchange, "direct");
                 channel.queueDeclare(queue, false, false, false, null);
@@ -86 +87 @@
 
                 // Declare the event topic fanout
+                System.out.println("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
                 channel.exchangeDeclare(UID, "fanout");
 
@@ -101 +103 @@
                         try {
                                 Delivery delivery = consumer.nextDelivery();
+                                System.out.println("RemoteObject: " + UID + " has received a message");
                                 remoteWrapper.notifyDelivery(delivery);
                         } catch (InterruptedException i) {