Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Apply patch for https://issues.apache.org/activemq/browse/AMQ-1758 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@661663 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-05-30 11:44:19 +00:00
parent db4f602e8c
commit 4ecc89eca0
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -1091,20 +1091,20 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
ensureConnectionInfoSent(); ensureConnectionInfoSent();
ConsumerId consumerId = createConsumerId(); ConsumerId consumerId = createConsumerId();
ConsumerInfo info = new ConsumerInfo(consumerId); ConsumerInfo consumerInfo = new ConsumerInfo(consumerId);
info.setDestination(ActiveMQMessageTransformation.transformDestination(destination)); consumerInfo.setDestination(ActiveMQMessageTransformation.transformDestination(destination));
info.setSelector(messageSelector); consumerInfo.setSelector(messageSelector);
info.setPrefetchSize(maxMessages); consumerInfo.setPrefetchSize(maxMessages);
info.setNoLocal(noLocal); consumerInfo.setNoLocal(noLocal);
info.setDispatchAsync(isDispatchAsync()); consumerInfo.setDispatchAsync(isDispatchAsync());
// Allows the options on the destination to configure the consumerInfo // Allows the options on the destination to configure the consumerInfo
if (info.getDestination().getOptions() != null) { if (consumerInfo.getDestination().getOptions() != null) {
Map<String, String> options = new HashMap<String, String>(info.getDestination().getOptions()); Map<String, String> options = new HashMap<String, String>(consumerInfo.getDestination().getOptions());
IntrospectionSupport.setProperties(info, options, "consumer."); IntrospectionSupport.setProperties(consumerInfo, options, "consumer.");
} }
return new ActiveMQConnectionConsumer(this, sessionPool, info); return new ActiveMQConnectionConsumer(this, sessionPool, consumerInfo);
} }
/** /**