From 4ecc89eca04546bcbdb1fdd72110fdf7c7c2b6a6 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Fri, 30 May 2008 11:44:19 +0000 Subject: [PATCH] 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 --- .../apache/activemq/ActiveMQConnection.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java index a1ae464c35..8586d40a5f 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java @@ -1091,20 +1091,20 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon ensureConnectionInfoSent(); ConsumerId consumerId = createConsumerId(); - ConsumerInfo info = new ConsumerInfo(consumerId); - info.setDestination(ActiveMQMessageTransformation.transformDestination(destination)); - info.setSelector(messageSelector); - info.setPrefetchSize(maxMessages); - info.setNoLocal(noLocal); - info.setDispatchAsync(isDispatchAsync()); + ConsumerInfo consumerInfo = new ConsumerInfo(consumerId); + consumerInfo.setDestination(ActiveMQMessageTransformation.transformDestination(destination)); + consumerInfo.setSelector(messageSelector); + consumerInfo.setPrefetchSize(maxMessages); + consumerInfo.setNoLocal(noLocal); + consumerInfo.setDispatchAsync(isDispatchAsync()); // Allows the options on the destination to configure the consumerInfo - if (info.getDestination().getOptions() != null) { - Map options = new HashMap(info.getDestination().getOptions()); - IntrospectionSupport.setProperties(info, options, "consumer."); + if (consumerInfo.getDestination().getOptions() != null) { + Map options = new HashMap(consumerInfo.getDestination().getOptions()); + IntrospectionSupport.setProperties(consumerInfo, options, "consumer."); } - return new ActiveMQConnectionConsumer(this, sessionPool, info); + return new ActiveMQConnectionConsumer(this, sessionPool, consumerInfo); } /**