Changeset 78 for trunk/src


Ignore:
Timestamp:
07/05/13 15:03:51 (11 years ago)
Author:
stoda
Message:

PersistentTest? added, persistent messages enabled

Location:
trunk/src
Files:
4 added
2 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/main/java/omq/client/proxy/MultiProxymq.java

    r77 r78  
    3939
    4040                Properties env = broker.getEnvironment();
    41                 replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
    4241                exchange = multi + uid;
    4342                serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
     
    5352
    5453                // Add the correlation ID and create a replyTo property
    55                 BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType).build();
     54                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).type(serializerType).build();
    5655
    5756                byte[] bytesRequest = serializer.serialize(serializerType, request);
  • trunk/src/test/java/omq/test/event/MessageTest.java

    r77 r78  
    2020@RunWith(value = Parameterized.class)
    2121public class MessageTest {
    22         private static final String NAME = "message";
     22        private static final String NAME = "message_event_test";
    2323
    2424        private static Broker broker;
Note: See TracChangeset for help on using the changeset viewer.