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

PersistentTest? added, persistent messages enabled

File:
1 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);
Note: See TracChangeset for help on using the changeset viewer.