Author: rajdavies
Date: Fri May 30 04:44:19 2008
New Revision: 661663
URL: http://svn.apache.org/viewvc?rev=661663&view=rev
Log:
Apply patch for https://issues.apache.org/activemq/browse/AMQ-1758
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=661663&r1=661662&r2=661663&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Fri May 30 04:44:19 2008
@@ -1091,20 +1091,20 @@
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<String, String> options = new HashMap<String,
String>(info.getDestination().getOptions());
- IntrospectionSupport.setProperties(info, options, "consumer.");
+ if (consumerInfo.getDestination().getOptions() != null) {
+ Map<String, String> options = new HashMap<String,
String>(consumerInfo.getDestination().getOptions());
+ IntrospectionSupport.setProperties(consumerInfo, options,
"consumer.");
}
- return new ActiveMQConnectionConsumer(this, sessionPool, info);
+ return new ActiveMQConnectionConsumer(this, sessionPool, consumerInfo);
}
/**
