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

Timestamp:

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

Author:

stoda

Message:

Adding @MultiMethod?
Broker is not a singleton.

Location:

trunk/src/main/java/omq/server

Files:

• InvocationThread.java (modified) (2 diffs)
• RemoteObject.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());
                                 }
 

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

@@ -35 +35 @@
 
         private static final long serialVersionUID = -1778953938739846450L;
+        private static final String multi = "multi#";
         private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
 
@@ -230 +231 @@
                 logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
                 channel.exchangeDeclare(exchange, "direct");
+                channel.exchangeDeclare(multi + exchange, "fanout");
                 channel.queueDeclare(queue, durable, false, false, null);
                 channel.queueBind(queue, exchange, routingKey);
+                channel.queueBind(queue, multi + exchange, routingKey);
 
                 // Declare the event topic fanout