Changeset 54 for trunk/src/main/java/omq/server/RemoteObject.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/RemoteObject.java (modified) (2 diffs)

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