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

Timestamp:

07/02/13 11:50:11 (11 years ago)

Author:

stoda

Message:

Multi problem solved

File:

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

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

@@ -97 +97 @@
                                 Delivery delivery = consumer.nextDelivery();
 
-                                logger.debug(UID + " has received a message");
+                                logger.debug(UID + " has received a message, serializer: " + delivery.getProperties().getType());
 
                                 remoteWrapper.notifyDelivery(delivery);
@@ -219 +219 @@
                 String routingKey = UID;
                 // Multi info
-                String multiExchange = multi + exchange;
+                String multiExchange = multi + UID;
 
                 boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));