You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/05/30 13:44:19 UTC
svn commit: r661663 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
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);
}
/**