Changeset 78 for trunk/src

Timestamp:

07/05/13 15:03:51 (11 years ago)

Author:

stoda

Message:

PersistentTest? added, persistent messages enabled

Location:

trunk/src

Files:

• main/java/omq/client/proxy/MultiProxymq.java (modified) (2 diffs)
• test/java/omq/test/event/MessageTest.java (modified) (1 diff)
• test/java/omq/test/persistence (added)
• test/java/omq/test/persistence/Message.java (added)
• test/java/omq/test/persistence/MessageImpl.java (added)
• test/java/omq/test/persistence/PersistentTest.java (added)

trunk/src/main/java/omq/client/proxy/MultiProxymq.java

@@ -39 +39 @@
 
                 Properties env = broker.getEnvironment();
-                replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
                 exchange = multi + uid;
                 serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
@@ -53 +52 @@
 
                 // Add the correlation ID and create a replyTo property
-                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType).build();
+                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).type(serializerType).build();
 
                 byte[] bytesRequest = serializer.serialize(serializerType, request);

trunk/src/test/java/omq/test/event/MessageTest.java

@@ -20 +20 @@
 @RunWith(value = Parameterized.class)
 public class MessageTest {
-        private static final String NAME = "message";
+        private static final String NAME = "message_event_test";
 
         private static Broker broker;