Changeset 54 for trunk/src/main/java/omq/server/InvocationThread.java

Timestamp:

06/21/13 12:42:25 (11 years ago)

Author:

stoda

Message:

Adding @MultiMethod?
Broker is not a singleton.

File:

• trunk/src/main/java/omq/server/InvocationThread.java (modified) (2 diffs)

trunk/src/main/java/omq/server/InvocationThread.java

@@ -44 +44 @@
                                 // Deserialize the json
                                 Request request = serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
-                                // Log.saveLog("Server-Deserialize", delivery.getBody());
-
                                 String methodName = request.getMethod();
                                 String requestID = request.getId();
@@ -77 +75 @@
                                         byte[] bytesResponse = serializer.serialize(serializerType, resp);
                                         channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);
-
-                                        // Log.saveLog("Server-Serialize", bytesResponse);
+                                        logger.debug("Publish sync response -> Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID + " replyTo: "
+                                                        + props.getReplyTo());
                                 }