Changeset 55 for trunk/src/main/java/omq/server/RemoteObject.java

Timestamp:

06/21/13 16:55:58 (11 years ago)

Author:

stoda

Message:

@MultiMethod? implemented and working with @AsyncMethod? annotation.
TODO: @Multi with SyncMethod?(waitNum = x) -> Must return a List<?>
Refactoring in Proxymq if it's necessary

File:

• trunk/src/main/java/omq/server/RemoteObject.java (modified) (3 diffs)

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

@@ -223 +223 @@
                 String queue = UID;
                 String routingKey = UID;
+                // Multi info
+                String multiExchange = multi + exchange;
+                String multiQueue = UID + System.currentTimeMillis();
+
                 boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
 
@@ -231 +235 @@
                 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);
+
+                channel.exchangeDeclare(multiExchange, "fanout");
+                channel.queueDeclare(multiQueue, durable, false, false, null);
+                channel.queueBind(multiQueue, multiExchange, "");
 
                 // Declare the event topic fanout
@@ -243 +249 @@
                 consumer = new QueueingConsumer(channel);
                 channel.basicConsume(queue, true, consumer);
+                channel.basicConsume(multiQueue, true, consumer);
         }