Changeset 78 for trunk/src/main

Timestamp:

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

Author:

stoda

Message:

PersistentTest? added, persistent messages enabled

File:

• trunk/src/main/java/omq/client/proxy/MultiProxymq.java (modified) (2 diffs)

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);